fix panic on recovering cluster (with peers.json) (#882)

distribworks · Jan 6, 2021 · 8c9b146 · 8c9b146
1 parent a29bbb7
commit 8c9b146
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/dkron/agent.go b/dkron/agent.go
@@ -327,7 +327,11 @@ func (a *Agent) setupRaft() error {
 			if err != nil {
 				return fmt.Errorf("recovery failed to parse peers.json: %v", err)
 			}
-			tmpFsm := newFSM(nil, nil)
+			store, err := NewStore()
+			if err != nil {
+				log.WithError(err).Fatal("dkron: Error initializing store")
+                        }
+			tmpFsm := newFSM(store, nil)
 			if err := raft.RecoverCluster(config, tmpFsm,
 				logStore, stableStore, snapshots, transport, configuration); err != nil {
 				return fmt.Errorf("recovery failed: %v", err)