Class PipelineStrategy

Namespace

JD.AI.Core.Agents.Orchestration.Strategies

Assembly

JD.AI.Core.dll

Pipeline strategy — a typed sequential execution where each agent's output is explicitly transformed before being passed to the next stage. Unlike Sequential/Relay which pass raw output, Pipeline stages have defined input/output contracts and can specify transform functions. Good for: CI/CD workflows, ETL processes, staged code review.

public sealed class PipelineStrategy : IOrchestrationStrategy

Inheritance

object

PipelineStrategy

Implements

IOrchestrationStrategy

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Properties

FailFast

When true, a failed stage halts the entire pipeline.

public bool FailFast { get; init; }

Property Value

bool

Name

The strategy name (sequential, fan-out, supervisor, debate).

public string Name { get; }

Property Value

string

StagePromptTemplate

Template for pipeline stage prompts. Supports {stage_input}, {stage_number}, {total_stages}, and {stage_role} placeholders.

public string StagePromptTemplate { get; init; }

Property Value

string

Methods

ExecuteAsync(IReadOnlyList<SubagentConfig>, TeamContext, ISubagentExecutor, AgentSession, Action<SubagentProgress>?, CancellationToken)

Execute the orchestration strategy with the given agents, context, and executor.

public Task<TeamResult> ExecuteAsync(IReadOnlyList<SubagentConfig> agents, TeamContext context, ISubagentExecutor executor, AgentSession parentSession, Action<SubagentProgress>? onProgress = null, CancellationToken ct = default)

Parameters

agents IReadOnlyList<SubagentConfig>

context TeamContext

executor ISubagentExecutor

parentSession AgentSession

onProgress Action<SubagentProgress>

ct CancellationToken

Returns

Task<TeamResult>