diff --git a/backend/src/monitor.rs b/backend/src/monitor.rs index 8da90fdbde..1a53418d28 100644 --- a/backend/src/monitor.rs +++ b/backend/src/monitor.rs @@ -1611,7 +1611,10 @@ pub async fn monitor_db( if server_mode && !initial_load { if let Some(db) = conn.as_sql() { if let Err(e) = cleanup_debounce_keys_for_completed_jobs(&db).await { - tracing::error!("Error cleaning up debounce keys for completed jobs: {:?}", e); + tracing::error!( + "Error cleaning up debounce keys for completed jobs: {:?}", + e + ); } } } @@ -2351,7 +2354,7 @@ async fn handle_zombie_jobs(db: &Pool, base_internal_url: &str, node_n memory_peak, None, error::Error::ExecutionErr(error_message), - true, + matches!(error_kind, ErrorMessage::SameWorker), // unrecoverable if the job is a same worker zombie Some(&same_worker_tx_never_used), "", node_name, @@ -2806,7 +2809,10 @@ RETURNING key,job_id async fn cleanup_debounce_keys_for_completed_jobs(db: &DB) -> error::Result<()> { // If min version doesn't support runnable settings, clean up debounce keys for completed jobs - if !*windmill_common::worker::MIN_VERSION_SUPPORTS_RUNNABLE_SETTINGS_V0.read().await { + if !*windmill_common::worker::MIN_VERSION_SUPPORTS_RUNNABLE_SETTINGS_V0 + .read() + .await + { let result = sqlx::query!( " DELETE FROM debounce_key