Class PipelineOrchestrator

Namespace: LMKit.Agents.Orchestration

Assembly: LM-Kit.NET.dll

Orchestrator that executes agents sequentially in a pipeline.

Each agent receives the output of the previous agent as its input, forming a chain of processing steps.

public sealed class PipelineOrchestrator : OrchestratorBase, IOrchestrator

Inheritance: object

OrchestratorBase

PipelineOrchestrator

Implements: IOrchestrator

Inherited Members: OrchestratorBase.DefaultOptions

OrchestratorBase.BeforeAgentExecution

OrchestratorBase.AfterAgentExecution

OrchestratorBase.ExecuteAsync(string, CancellationToken)

OrchestratorBase.ExecuteAsync(string, OrchestrationOptions, CancellationToken)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Examples

var pipeline = new PipelineOrchestrator()
    .AddStage(extractorAgent)
    .AddStage(summarizerAgent)
    .AddStage(translatorAgent);

var result = await pipeline.ExecuteAsync("Process this document...");

Remarks

Use Cases

Multi-step document processing (extract, summarize, translate)
Data transformation pipelines
Iterative refinement workflows

Constructors

PipelineOrchestrator(): Initializes a new instance of the PipelineOrchestrator class.

PipelineOrchestrator(params Agent[]): Initializes a pipeline with the specified agents.

Properties

Name: Gets the name of this orchestrator.

Stages: Gets the stages in this pipeline.

Methods

AddStage(Agent): Adds an agent as the next stage in the pipeline.

AddStage(Agent, Func<string, OrchestrationContext, string>): Adds a stage with an input transformer.

AddStage(string, Agent): Adds a named stage to the pipeline.

ExecuteCoreAsync(OrchestrationContext, OrchestrationOptions, CancellationToken): Executes the pipeline.