Skip to main content

polling_loop

Function polling_loop 

Source
pub async fn polling_loop<R: CommandRunner + 'static>(
    executor: Arc<PipelineExecutor<R>>,
    auto_merge: bool,
    cancel_token: CancellationToken,
) -> Result<()>
Expand description

Poll for new issues and run them through the pipeline.

Unlike run_batch, this function continuously polls for new issues even while existing pipelines are running. The DependencyGraph is the single source of truth: ready_issues() drives scheduling, transition() replaces manual map mutations, and propagate_failure() handles dependency cascades.