diff --git a/pkg/dt/storage/etcd/etcd.go b/pkg/dt/storage/etcd/etcd.go index 512abf7..1c14263 100644 --- a/pkg/dt/storage/etcd/etcd.go +++ b/pkg/dt/storage/etcd/etcd.go @@ -85,7 +85,7 @@ func (s *store) LeaderElection(applicationID string) bool { e := concurrency.NewElection(s.session, fmt.Sprintf("%s/leader-election/", applicationID)) ctx := context.Background() // Elect a leader (or wait that the leader resign) - if err := e.Campaign(ctx, "e"); err != nil { + if err := e.Campaign(ctx, applicationID); err != nil { log.Fatal(err) } return true