Skip to content

Commit

Permalink
chore: Remove duration in TaskAbort timeout log
Browse files Browse the repository at this point in the history
  • Loading branch information
leo91000 committed Dec 26, 2023
1 parent adfb5a8 commit 5afcbdd
Showing 1 changed file with 2 additions and 3 deletions.
5 changes: 2 additions & 3 deletions src/runner.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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"
);

Expand Down

0 comments on commit 5afcbdd

Please sign in to comment.