From dc887e5f43d87305995b25d4b781df00a2be10c4 Mon Sep 17 00:00:00 2001
From: Ruben Fiszel <ruben@windmill.dev>
Date: Thu, 23 Oct 2025 07:41:27 +0000
Subject: [PATCH] remove erronous error log in agent mode

---
 backend/windmill-worker/src/worker.rs | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/backend/windmill-worker/src/worker.rs b/backend/windmill-worker/src/worker.rs
index eb16e3f5f4..16abf40c86 100644
--- a/backend/windmill-worker/src/worker.rs
+++ b/backend/windmill-worker/src/worker.rs
@@ -466,6 +466,12 @@ pub enum JobCompletedSender {
     NeverUsed,
 }
 
+impl JobCompletedSender {
+    pub fn is_sql(&self) -> bool {
+        matches!(self, Self::Sql(_))
+    }
+}
+
 #[derive(Clone)]
 pub struct SqlJobCompletedSender {
     sender: flume::Sender<SendResult>,
@@ -1536,7 +1542,7 @@ pub async fn run_worker(
                 Ok(_) | Err(broadcast::error::TryRecvError::Closed) => true,
                 _ => false,
             } {
-                if !killed_but_draining_same_worker_jobs {
+                if !killed_but_draining_same_worker_jobs && job_completed_tx.is_sql() {
                     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