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], ) -> Option<PlannerOutput>

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

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