Skip to content

Commit

Permalink
handle little case
Browse files Browse the repository at this point in the history
  • Loading branch information
Guocork committed Sep 6, 2024
1 parent 34bdb92 commit c98d03c
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion controllers/src/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@ async fn main() -> anyhow::Result<()> {
_ = actor_controller::new(&ctx) => tracing::warn!("actor controller exited"),
_ = credentials_watcher::new(&ctx) => tracing::warn!("credentials watcher exited"),
_ = namespace_watcher::new(&ctx) => tracing::warn!("namespace watcher exited"),
_ = timeout_controller::new(&ctx) => tracing::warn!("timeout_controller exited")
_ = timeout_controller::new(&ctx) => tracing::warn!("timeout controller exited")
}

Ok(())
Expand Down
4 changes: 2 additions & 2 deletions controllers/src/timeout_controller.rs
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@ pub async fn new(ctx: &Arc<Context>) {
error!("Failed to wait until ready: {:?}", e);
return;
}
info!("Timeout_controller is running...");
info!("Timeout controller is running...");
loop {
for p in reader.state() {
if let Err(err) = handle(p.as_ref(), &client).await {
Expand Down Expand Up @@ -95,7 +95,7 @@ async fn handle(playbook: &Playbook, client: &Client) -> anyhow::Result<()> {
}
},
Strategy::Remain(time) => {
if time <= Duration::days(3) {
if time == Duration::days(3) {
send_message().await;
}
},
Expand Down

0 comments on commit c98d03c

Please sign in to comment.