Struct PipelineExecutor 

pub struct PipelineExecutor<R: CommandRunner> {
    pub runner: Arc<R>,
    pub github: Arc<GhClient<R>>,
    pub issues: Arc<dyn IssueProvider>,
    pub db: Arc<Mutex<Connection>>,
    pub config: Config,
    pub cancel_token: CancellationToken,
    pub repo_dir: PathBuf,
}

Runs a single issue through the full pipeline.

Fields

runner: Arc<R>

github: Arc<GhClient<R>>

issues: Arc<dyn IssueProvider>

db: Arc<Mutex<Connection>>

config: Config

cancel_token: CancellationToken

repo_dir: PathBuf

Implementations

impl<R: CommandRunner + 'static> PipelineExecutor<R>

pub async fn run_issue( &self, issue: &PipelineIssue, auto_merge: bool, ) -> Result<()>

Run the full pipeline for a single issue.

pub async fn run_issue_with_complexity( &self, issue: &PipelineIssue, auto_merge: bool, complexity: Option<Complexity>, ) -> Result<()>

Run the full pipeline for a single issue with an optional complexity classification.

pub async fn plan_issues( &self, issues: &[PipelineIssue], in_flight: &[InFlightIssue], ) -> Option<PlannerOutput>

Invoke the planner agent to decide batching and complexity for a set of issues.

in_flight describes issues currently running through the pipeline so the planner can avoid scheduling conflicting work in batch 1.

Returns None if the planner fails or returns unparseable output (fallback to default).