From 1456f73c166fa525322d74664d930cd6c2b19a1e Mon Sep 17 00:00:00 2001
From: Ruben Fiszel <ruben@windmill.dev>
Date: Mon, 9 Feb 2026 22:51:57 +0000
Subject: [PATCH] nit test

---
 backend/ee-repo-ref.txt                         | 2 +-
 backend/windmill-queue/src/jobs.rs              | 4 ----
 backend/windmill-worker/src/result_processor.rs | 2 --
 backend/windmill-worker/src/worker_flow.rs      | 2 --
 4 files changed, 1 insertion(+), 9 deletions(-)

diff --git a/backend/ee-repo-ref.txt b/backend/ee-repo-ref.txt
index bc27a919a2..6496156c79 100644
--- a/backend/ee-repo-ref.txt
+++ b/backend/ee-repo-ref.txt
@@ -1 +1 @@
-b1916254951d504db136759f4150a40d3a88a638
+7596cefdba81482c0b0c0b61be26369f112d8009
\ No newline at end of file
diff --git a/backend/windmill-queue/src/jobs.rs b/backend/windmill-queue/src/jobs.rs
index a6148922f0..b298fed82c 100644
--- a/backend/windmill-queue/src/jobs.rs
+++ b/backend/windmill-queue/src/jobs.rs
@@ -782,7 +782,6 @@ pub async fn add_completed_job_error(
         flow_is_done,
         duration,
         false,
-        false,
     )
     .warn_after_seconds(10)
     .await?;
@@ -818,7 +817,6 @@ pub async fn add_completed_job<T: Serialize + Send + Sync + ValidableJson>(
     canceled_by: Option<CanceledBy>,
     flow_is_done: bool,
     duration: Option<i64>,
-    has_stream: bool,
     from_cache: bool,
 ) -> Result<(Uuid, i64), Error> {
     // tracing::error!("Start");
@@ -844,7 +842,6 @@ pub async fn add_completed_job<T: Serialize + Send + Sync + ValidableJson>(
             &canceled_by,
             flow_is_done,
             duration,
-            has_stream,
             from_cache,
         )
         .warn_after_seconds(10)
@@ -904,7 +901,6 @@ async fn commit_completed_job<T: Serialize + Send + Sync + ValidableJson>(
     canceled_by: &Option<CanceledBy>,
     flow_is_done: bool,
     duration: Option<i64>,
-    has_stream: bool,
     from_cache: bool,
 ) -> windmill_common::error::Result<(Option<Uuid>, i64, bool)> {
     // let start = std::time::Instant::now();
diff --git a/backend/windmill-worker/src/result_processor.rs b/backend/windmill-worker/src/result_processor.rs
index c2a2b5a001..6992d6ff74 100644
--- a/backend/windmill-worker/src/result_processor.rs
+++ b/backend/windmill-worker/src/result_processor.rs
@@ -586,7 +586,6 @@ pub async fn process_completed_job(
         duration,
         result_columns,
         preprocessed_args,
-        has_stream,
         from_cache,
         flow_runners,
         done_tx,
@@ -655,7 +654,6 @@ pub async fn process_completed_job(
             canceled_by.clone(),
             false,
             duration,
-            has_stream.unwrap_or(false),
             from_cache.unwrap_or(false),
         )
         .await?;
diff --git a/backend/windmill-worker/src/worker_flow.rs b/backend/windmill-worker/src/worker_flow.rs
index b1ef84f342..7b013bda9e 100644
--- a/backend/windmill-worker/src/worker_flow.rs
+++ b/backend/windmill-worker/src/worker_flow.rs
@@ -1640,7 +1640,6 @@ pub async fn update_flow_status_after_job_completion_internal(
                     true,
                     None,
                     false,
-                    false,
                 )
                 .await?;
                 duration
@@ -1661,7 +1660,6 @@ pub async fn update_flow_status_after_job_completion_internal(
                     true,
                     None,
                     false,
-                    false,
                 )
                 .await?;
                 duration