starred/windmill
1
0
Fork 0
mirror of https://github.com/windmill-labs/windmill.git synced 2026-08-20 16:02:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix agent worker nits

Browse Source
This commit is contained in:
Ruben Fiszel
2025-10-24 19:32:41 +00:00
parent 999aaaacd8
commit 4cee047ebc
1 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/windmill-worker/src/worker.rs
+8 -6
View File
@@ -1542,13 +1542,15 @@ pub async fn run_worker(
Ok(_) | Err(broadcast::error::TryRecvError::Closed) => true,
_ => false,
} {
if !killed_but_draining_same_worker_jobs && job_completed_tx.is_sql() {
if !killed_but_draining_same_worker_jobs {
killed_but_draining_same_worker_jobs = true;
tracing::info!(worker = %worker_name, hostname = %hostname, "killpill received in worker main loop, sending killpill job");
job_completed_tx
.kill()
.await
.expect("send kill to job completed tx");
if job_completed_tx.is_sql() {
tracing::info!(worker = %worker_name, hostname = %hostname, "killpill received in worker main loop, sending killpill job");
job_completed_tx
.kill()
.await
.expect("send kill to job completed tx");
}
}
continue;
} else if killed_but_draining_same_worker_jobs {