Signed-off-by: kjuulh <contact@kjuulh.io>
This commit is contained in:
parent
55498adffd
commit
84820dcc82
@ -37,6 +37,7 @@ where
|
|||||||
let start = std::time::Instant::now();
|
let start = std::time::Instant::now();
|
||||||
|
|
||||||
tracing::debug!("running job");
|
tracing::debug!("running job");
|
||||||
|
let child_token = cancellation_token.child_token();
|
||||||
if let Err(e) = drifter.execute(child_token).await {
|
if let Err(e) = drifter.execute(child_token).await {
|
||||||
tracing::error!("drift job failed with error: {}, stopping routine", e);
|
tracing::error!("drift job failed with error: {}, stopping routine", e);
|
||||||
cancellation_token.cancel();
|
cancellation_token.cancel();
|
||||||
|
Loading…
Reference in New Issue
Block a user