pub async fn run_coordinator(
registry: TaskRegistry,
rx: Receiver<CoordinatorMessage>,
runtime: SharedRuntime,
engine: StandardEngine,
)Expand description
Run the coordinator loop
pub async fn run_coordinator(
registry: TaskRegistry,
rx: Receiver<CoordinatorMessage>,
runtime: SharedRuntime,
engine: StandardEngine,
)Run the coordinator loop