chore: Increase flow status update warning timeout

backend/windmill-common/src/job_metrics.rs

@@ -87,7 +87,7 @@ pub async fn register_metric_for_job(
     .bind(timeseries_int)
     .bind(timeseries_float)
     .execute(db)
-    .warn_after_seconds(1)
+    .warn_after_seconds(10)
     .await?;
 
     Ok(metric_id)

backend/windmill-queue/src/flow_status.rs

@@ -104,7 +104,7 @@ pub async fn update_workflow_as_code_status(
         parent_job
     )
     .execute(db)
-    .warn_after_seconds(5)
+    .warn_after_seconds(10)
     .await
     .inspect_err(|e| {
         tracing::error!(

backend/windmill-queue/src/jobs.rs

@@ -4715,4 +4715,4 @@ pub async fn get_same_worker_job(
             same_worker_job.job_id, e
         ))
     })
-}
+}

backend/windmill-worker/src/job_logger.rs

@@ -75,7 +75,7 @@ pub async fn append_logs_with_compaction(
         &w_id,
     )
     .fetch_one(db)
-    .warn_after_seconds(1)
+    .warn_after_seconds(10)
     .await;
     match log_length {
         Ok(length) => {

backend/windmill-worker/src/result_processor.rs

@@ -543,7 +543,7 @@ pub async fn process_completed_job(
                     #[cfg(feature = "benchmark")]
                     bench,
                 )
-                .warn_after_seconds(10)
+                .warn_after_seconds(20)
                 .await?;
                 add_time!(bench, "updated flow status END");
                 return Ok(r);
@@ -583,7 +583,7 @@ pub async fn process_completed_job(
                     #[cfg(feature = "benchmark")]
                     bench,
                 )
-                .warn_after_seconds(10)
+                .warn_after_seconds(20)
                 .await?;
                 return Ok(r);
             }

backend/windmill-worker/src/worker_flow.rs

@@ -1294,7 +1294,7 @@ pub async fn update_flow_status_after_job_completion_internal(
             job_completed_tx,
             worker_name,
         )
-        .warn_after_seconds(10)
+        .warn_after_seconds(20)
         .await
         {
             Err(err) => {
@@ -1606,7 +1606,7 @@ pub async fn handle_flow(
         let schedule_path = schedule_path.as_ref().unwrap();
 
         let schedule = get_schedule_opt(db, &flow_job.workspace_id, schedule_path)
-            .warn_after_seconds(5)
+            .warn_after_seconds(10)
             .await?;
 
         if let Some(schedule) = schedule {
@@ -1617,7 +1617,7 @@ pub async fn handle_flow(
                 flow_job.runnable_path.as_ref().unwrap(),
                 &flow_job.workspace_id,
             )
-            .warn_after_seconds(5)
+            .warn_after_seconds(10)
             .await
             {
                 match err {
@@ -1647,7 +1647,7 @@ pub async fn handle_flow(
             worker_dir,
             worker_name,
         )
-        .warn_after_seconds(10)
+        .warn_after_seconds(20)
         .await?;
         match next {
             PushNextFlowJob::Rec(nrec) => {
@@ -1663,7 +1663,7 @@ pub async fn handle_flow(
                     );
                     job_completed_tx
                         .send(SendResult::UpdateFlow(update_flow), false)
-                        .warn_after_seconds(3)
+                        .warn_after_seconds(10)
                         .await
                         .map_err(|e| {
                             Error::internal_err(format!(
@@ -1797,7 +1797,7 @@ async fn push_next_flow_job(
                 flow_job.workspace_id.as_str()
             )
             .fetch_one(db)
-            .warn_after_seconds(3)
+            .warn_after_seconds(10)
             .await?;
             if no_flow_overlap {
                 let overlapping = sqlx::query_scalar!(
@@ -1818,7 +1818,7 @@ async fn push_next_flow_job(
                      flow_job.runnable_path()
                  )
                  .fetch_all(db)
-                 .warn_after_seconds(3)
+                 .warn_after_seconds(10)
                  .await?;
                 if overlapping.len() > 0 {
                     let overlapping_str = overlapping