Merge pull request #73 from victorcoder/fix-gone-member

Fixes node processing with wrong status
distribworks · Feb 11, 2016 · 2620458 · 2620458
2 parents 0bf63b7 + e7a4888
commit 2620458
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/dkron/agent.go b/dkron/agent.go
@@ -763,10 +763,12 @@ func (a *AgentCommand) processFilteredNodes(job *Job) ([]string, map[string]stri
 			}
 
 			for _, member := range a.serf.Members() {
-				for mtk, mtv := range member.Tags {
-					if mtk == jtk && mtv == tv {
-						if len(nodes) < count {
-							nodes = append(nodes, member.Name)
+				if member.Status == serf.StatusAlive {
+					for mtk, mtv := range member.Tags {
+						if mtk == jtk && mtv == tv {
+							if len(nodes) < count {
+								nodes = append(nodes, member.Name)
+							}
 						}
 					}
 				}