huskies: merge 470_story_reduce_timer_tick_interval_to_1_second_and_suppress_idle_tick_logging
This commit is contained in:
@@ -134,7 +134,7 @@ impl TimerStore {
|
|||||||
|
|
||||||
// ── Tick loop ──────────────────────────────────────────────────────────────
|
// ── Tick loop ──────────────────────────────────────────────────────────────
|
||||||
|
|
||||||
/// Spawn a background tokio task that fires due timers every 30 seconds.
|
/// Spawn a background tokio task that fires due timers every 1 second.
|
||||||
///
|
///
|
||||||
/// Same pattern as the watchdog in `agents::pool::auto_assign`.
|
/// Same pattern as the watchdog in `agents::pool::auto_assign`.
|
||||||
/// When a timer fires, `start_agent` is called for the story. If all coders
|
/// When a timer fires, `start_agent` is called for the story. If all coders
|
||||||
@@ -153,7 +153,7 @@ pub fn spawn_timer_tick_loop(
|
|||||||
);
|
);
|
||||||
|
|
||||||
tokio::spawn(async move {
|
tokio::spawn(async move {
|
||||||
let mut interval = tokio::time::interval(std::time::Duration::from_secs(30));
|
let mut interval = tokio::time::interval(std::time::Duration::from_secs(1));
|
||||||
loop {
|
loop {
|
||||||
interval.tick().await;
|
interval.tick().await;
|
||||||
|
|
||||||
@@ -187,6 +187,10 @@ async fn tick_once(
|
|||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
|
if due.is_empty() {
|
||||||
|
return Ok(());
|
||||||
|
}
|
||||||
|
|
||||||
let remaining = store.list().len();
|
let remaining = store.list().len();
|
||||||
crate::slog!(
|
crate::slog!(
|
||||||
"[timer] Tick: {} due, {remaining} remaining",
|
"[timer] Tick: {} due, {remaining} remaining",
|
||||||
|
|||||||
Reference in New Issue
Block a user