diff --git a/crates/coordination/src/k8s.rs b/crates/coordination/src/k8s.rs index 3881880..f2579fd 100644 --- a/crates/coordination/src/k8s.rs +++ b/crates/coordination/src/k8s.rs @@ -102,6 +102,7 @@ where } Err(err) => { error!("Error while k8s leader election: {err:?}"); + shutdown(epoch, am_i_leader, lease_lock).await; return Err(Box::new(err)); } } @@ -148,6 +149,7 @@ where } Err(err) => { error!("Error while k8s leader election: {err:?}"); + shutdown(epoch, am_i_leader, lease_lock).await; return Err(Box::new(err)); } }