diff --git a/crates/federate/src/worker.rs b/crates/federate/src/worker.rs index 6dff325b6..e9e5fb708 100644 --- a/crates/federate/src/worker.rs +++ b/crates/federate/src/worker.rs @@ -152,7 +152,15 @@ impl InstanceWorker { self.save_and_send_state(pool).await?; latest_id }; - if id == latest_id { + if id >= latest_id { + if id > latest_id { + tracing::error!( + "{}: last successful id {} is higher than latest id {} in database (did the db get cleared?)", + self.instance.domain, + id.0, + latest_id.0 + ); + } // no more work to be done, wait before rechecking tokio::select! { () = sleep(*WORK_FINISHED_RECHECK_DELAY) => {},