nit test

backend/ee-repo-ref.txt

@@ -1 +1 @@
-b1916254951d504db136759f4150a40d3a88a638
+7596cefdba81482c0b0c0b61be26369f112d8009

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();

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?;

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