IStageExecutor

NexusLabs.Needlr.AgentFramework.Workflows

NexusLabs.Needlr.AgentFramework.Workflows.Sequential

IStageExecutor Interface

Defines the execution strategy for a single pipeline stage. Implementations include agent-driven stages, programmatic/delegate stages, and critique-and-revise loops.

public interface IStageExecutor

Derived
↳ AgentStageExecutor
↳ ContinueOnFailureExecutor
↳ CritiqueAndReviseExecutor
↳ DelegateStageExecutor
↳ FallbackExecutor
↳ TimeoutExecutor

Example

public class MyCustomExecutor : IStageExecutor
{
    public async Task<StageExecutionResult> ExecuteAsync(
        StageExecutionContext context,
        CancellationToken cancellationToken)
    {
        // Custom stage logic here
        return StageExecutionResult.Success(context.StageName, diagnostics: null, responseText: "done");
    }
}

Methods

IStageExecutor.ExecuteAsync(StageExecutionContext, CancellationToken) Method

Executes the stage logic and returns a result indicating success or failure.

System.Threading.Tasks.Task<NexusLabs.Needlr.AgentFramework.Workflows.Sequential.StageExecutionResult> ExecuteAsync(NexusLabs.Needlr.AgentFramework.Workflows.Sequential.StageExecutionContext context, System.Threading.CancellationToken cancellationToken);

Parameters

context StageExecutionContext

The execution context providing access to shared pipeline state.

cancellationToken System.Threading.CancellationToken

Token to observe for cancellation.

Returns

System.Threading.Tasks.Task<StageExecutionResult>
A StageExecutionResult describing the outcome.