Fix cluster panic bug

distribworks · Sep 8, 2018 · ad1d651 · ad1d651
1 parent c86dcf6
commit ad1d651
Showing 1 changed file with 9 additions and 7 deletions.
diff --git a/dkron/agent.go b/dkron/agent.go
@@ -90,6 +90,15 @@ func (a *Agent) Start() error {
 	if a.config.Server {
 		a.StartServer()
 	}
+
+	if a.GRPCClient == nil {
+		a.GRPCClient = NewGRPCClient(nil)
+	}
+
+	if err := a.SetTags(a.config.Tags); err != nil {
+		log.WithError(err).Fatal("agent: Error setting RPC config tags")
+	}
+
 	go a.eventLoop()
 	a.ready = true
 
@@ -298,13 +307,6 @@ func (a *Agent) StartServer() {
 		log.WithError(err).Fatal("agent: RPC server failed to start")
 	}
 
-	if a.GRPCClient == nil {
-		a.GRPCClient = NewGRPCClient(nil)
-	}
-
-	if err := a.SetTags(a.config.Tags); err != nil {
-		log.WithError(err).Fatal("agent: Error setting RPC config tags")
-	}
 	a.participate()
 }