diff --git a/crates/nocontrol/src/control_plane/backing_store.rs b/crates/nocontrol/src/control_plane/backing_store.rs index 7a905cf..c4c6d5d 100644 --- a/crates/nocontrol/src/control_plane/backing_store.rs +++ b/crates/nocontrol/src/control_plane/backing_store.rs @@ -28,7 +28,7 @@ impl BackingStore { &self, worker_id: &WorkerId, ) -> anyhow::Result>> { - let now = jiff::Timestamp::now().checked_sub(1.second())?; + let now = jiff::Timestamp::now().checked_sub(10.second())?; let manifests = self .manifests .read() @@ -36,7 +36,7 @@ impl BackingStore { .iter() .filter(|m| match &m.lease { Some(lease) if lease.last_seen < now => true, - Some(lease) if &lease.owner == worker_id => true, + Some(lease) if &lease.owner == worker_id && lease.last_seen > now => true, Some(_lease) => false, None => true, })