Struct Reaper 

pub struct Reaper { /* private fields */ }

Periodic task that requeues runs whose worker lease expired.

Examples

use std::sync::Arc;
use std::time::Duration;
use ironflow_api::reaper::Reaper;
use ironflow_core::providers::claude::ClaudeCodeProvider;
use ironflow_engine::engine::Engine;
use ironflow_store::memory::InMemoryStore;
use ironflow_store::store::Store;
use tokio_util::sync::CancellationToken;

let store: Arc<dyn Store> = Arc::new(InMemoryStore::new());
let engine = Arc::new(Engine::new(store.clone(), Arc::new(ClaudeCodeProvider::new())));

let reaper = Reaper::new(store, engine).interval(Duration::from_secs(30));
tokio::spawn(reaper.run(CancellationToken::new()));

Implementations

impl Reaper

pub fn new(store: Arc<dyn Store>, engine: Arc<Engine>) -> Self

Create a reaper with the default interval and batch size.

pub fn interval(self, interval: Duration) -> Self

Set how often expired leases are collected.

Keep it well below the worker lease TTL, otherwise recovery takes longer than the TTL suggests.

pub fn batch_size(self, batch_size: u32) -> Self

Set how many runs a single tick recovers.

pub async fn run(self, shutdown: CancellationToken)

Run the recovery loop until shutdown is cancelled.

Store errors are logged and the loop keeps going: a transient database failure must not silently stop recovery.

pub async fn tick(&self)

Recover one batch of expired leases.

Exposed for tests and for callers that drive the schedule themselves.