diff --git a/backend/windmill-worker/src/worker.rs b/backend/windmill-worker/src/worker.rs index 9c71e304fc..990cf53cb7 100644 --- a/backend/windmill-worker/src/worker.rs +++ b/backend/windmill-worker/src/worker.rs @@ -2755,7 +2755,7 @@ async fn handle_zombie_jobs(db: &Pool, base_internal_url: &str) { let mut timeout_query = "SELECT * FROM queue WHERE last_ping < now() - ($1 || ' seconds')::interval AND running = true AND job_kind != $2".to_string(); if *RESTART_ZOMBIE_JOBS { - timeout_query.push_str("AND same_worker = true"); + timeout_query.push_str(" AND same_worker = true"); }; let timeouts = sqlx::query_as::<_, QueuedJob>( &timeout_query