From 5afcbdd18f3e4e96d5904e00be441c5466c112ec Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?L=C3=A9o=20Coletta?= <contact@leo-coletta.fr>
Date: Tue, 26 Dec 2023 17:02:04 +0100
Subject: [PATCH] chore: Remove duration in TaskAbort timeout log

---
 src/runner.rs | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/src/runner.rs b/src/runner.rs
index 0160dd8..1dedcfb 100644
--- a/src/runner.rs
+++ b/src/runner.rs
@@ -206,19 +206,18 @@ async fn run_job(job: &Job, worker: &Worker, source: &StreamSource) -> Result<()
             res.map_err(RunJobError::TaskPanic).and_then(|res| res.map_err(RunJobError::TaskError))
         }
         _ = shutdown_timeout => {
-            error!(task_identifier, payload, job_id = job.id(), timeout = 10, "Job interrupted by shutdown signal after timeout");
+            warn!(task_identifier, payload, job_id = job.id(), "Job interrupted by shutdown signal after 5 seconds timeout");
             abort_handle.abort();
             Err(RunJobError::TaskAborted)
         }
     }?;
     let duration = start.elapsed();
-    let duration = duration.as_millis();
 
     info!(
         task_identifier,
         payload,
         job_id = job.id(),
-        duration,
+        duration = duration.as_millis(),
         "Completed task with success"
     );