PipelineRunExtensions

NexusLabs.Needlr.AgentFramework.Workflows

NexusLabs.Needlr.AgentFramework.Workflows.Diagnostics

PipelineRunExtensions Class

Extension methods for running workflows with per-stage diagnostics and real-time progress reporting.

public static class PipelineRunExtensions

Inheritance System.Object 🡒 PipelineRunExtensions

Methods

PipelineRunExtensions.RunWithDiagnosticsAsync(this Workflow, string, IAgentDiagnosticsAccessor, IProgressReporter, IChatCompletionCollector, IProgressReporterAccessor, CancellationToken) Method

Executes the workflow with per-stage diagnostics, real-time progress reporting, and per-LLM-call completion draining via the provided collector.

public static System.Threading.Tasks.Task<NexusLabs.Needlr.AgentFramework.Diagnostics.IPipelineRunResult> RunWithDiagnosticsAsync(this Microsoft.Agents.AI.Workflows.Workflow workflow, string message, NexusLabs.Needlr.AgentFramework.Diagnostics.IAgentDiagnosticsAccessor diagnosticsAccessor, NexusLabs.Needlr.AgentFramework.Progress.IProgressReporter? progressReporter, NexusLabs.Needlr.AgentFramework.Diagnostics.IChatCompletionCollector? completionCollector, NexusLabs.Needlr.AgentFramework.Progress.IProgressReporterAccessor? progressReporterAccessor=null, System.Threading.CancellationToken cancellationToken=default(System.Threading.CancellationToken));

Parameters

workflow Microsoft.Agents.AI.Workflows.Workflow

message System.String

diagnosticsAccessor NexusLabs.Needlr.AgentFramework.Diagnostics.IAgentDiagnosticsAccessor

progressReporter NexusLabs.Needlr.AgentFramework.Progress.IProgressReporter

completionCollector NexusLabs.Needlr.AgentFramework.Diagnostics.IChatCompletionCollector

progressReporterAccessor NexusLabs.Needlr.AgentFramework.Progress.IProgressReporterAccessor

cancellationToken System.Threading.CancellationToken

Returns

System.Threading.Tasks.Task<NexusLabs.Needlr.AgentFramework.Diagnostics.IPipelineRunResult>

PipelineRunExtensions.RunWithDiagnosticsAsync(this Workflow, string, IAgentDiagnosticsAccessor, IProgressReporter, CancellationToken) Method

Executes the workflow with per-stage diagnostics and real-time progress reporting.

public static System.Threading.Tasks.Task<NexusLabs.Needlr.AgentFramework.Diagnostics.IPipelineRunResult> RunWithDiagnosticsAsync(this Microsoft.Agents.AI.Workflows.Workflow workflow, string message, NexusLabs.Needlr.AgentFramework.Diagnostics.IAgentDiagnosticsAccessor diagnosticsAccessor, NexusLabs.Needlr.AgentFramework.Progress.IProgressReporter? progressReporter, System.Threading.CancellationToken cancellationToken=default(System.Threading.CancellationToken));

Parameters

workflow Microsoft.Agents.AI.Workflows.Workflow

message System.String

diagnosticsAccessor NexusLabs.Needlr.AgentFramework.Diagnostics.IAgentDiagnosticsAccessor

progressReporter NexusLabs.Needlr.AgentFramework.Progress.IProgressReporter

cancellationToken System.Threading.CancellationToken

Returns

System.Threading.Tasks.Task<NexusLabs.Needlr.AgentFramework.Diagnostics.IPipelineRunResult>

PipelineRunExtensions.RunWithDiagnosticsAsync(this Workflow, string, IAgentDiagnosticsAccessor, CancellationToken) Method

Executes the workflow with per-stage diagnostics (no progress reporting).

public static System.Threading.Tasks.Task<NexusLabs.Needlr.AgentFramework.Diagnostics.IPipelineRunResult> RunWithDiagnosticsAsync(this Microsoft.Agents.AI.Workflows.Workflow workflow, string message, NexusLabs.Needlr.AgentFramework.Diagnostics.IAgentDiagnosticsAccessor diagnosticsAccessor, System.Threading.CancellationToken cancellationToken=default(System.Threading.CancellationToken));

Parameters

workflow Microsoft.Agents.AI.Workflows.Workflow

message System.String

diagnosticsAccessor NexusLabs.Needlr.AgentFramework.Diagnostics.IAgentDiagnosticsAccessor

cancellationToken System.Threading.CancellationToken

Returns

System.Threading.Tasks.Task<NexusLabs.Needlr.AgentFramework.Diagnostics.IPipelineRunResult>

PipelineRunExtensions.RunWithDiagnosticsAsync(this Workflow, string, WorkflowRunOptions) Method

Executes the workflow with per-stage diagnostics and progress reporting configured via NexusLabs.Needlr.AgentFramework.Diagnostics.WorkflowRunOptions.

public static System.Threading.Tasks.Task<NexusLabs.Needlr.AgentFramework.Diagnostics.IPipelineRunResult> RunWithDiagnosticsAsync(this Microsoft.Agents.AI.Workflows.Workflow workflow, string message, NexusLabs.Needlr.AgentFramework.Diagnostics.WorkflowRunOptions options);

Parameters

workflow Microsoft.Agents.AI.Workflows.Workflow

The workflow to execute.

message System.String

The user message to send.

options NexusLabs.Needlr.AgentFramework.Diagnostics.WorkflowRunOptions

Configuration for diagnostics, progress, and completion collection.

Returns

System.Threading.Tasks.Task<NexusLabs.Needlr.AgentFramework.Diagnostics.IPipelineRunResult>