Configures the passive Durable Task worker adapter.
Options describe retry intent for host-owned Durable Task activity scheduling. They do not register workers, create storage providers, or execute retries by themselves.
FlowRetryPolicy? ExecutorRetryPolicy { get; set; }
Source
Gets or sets the retry policy attached to executor scheduling decisions.
Hosts translate this value into Durable Task activity retry options when a claim maps to DurableTaskWorkerDecisionKind.ScheduleExecutor
.
FlowRetryPolicy? ProjectionRetryPolicy { get; set; }
Source
Gets or sets the retry policy attached to projection repair scheduling decisions.
Hosts translate this value into Durable Task activity retry options when a completion maps to DurableTaskWorkerDecisionKind.RepairProjection
.
Maps durable worker projection contract results into Durable Task-facing decisions.
TWork
TResult
TProjection
The runner is an adapter, not a hosted runtime. It calls the app-owned projection contract and returns decisions for host-owned Durable Task orchestration code to interpret. It never invokes IDurableWorkerExecutor{TWork,TResult}
from projection repair methods. The expected stage order is IDurableTaskWorkerChainRunner{TWork,TResult,TProjection}.TryClaimAsync
before executor activity, IDurableTaskWorkerChainRunner{TWork,TResult,TProjection}.CompleteAsync
after terminal executor activity, then IDurableTaskWorkerChainRunner{TWork,TResult,TProjection}.ReconcileProjectionAsync
for visible-state repair. Retry policies carried by decisions are advisory metadata; hosts translate them into Durable Task retry options, timers, or activity scheduling behavior.
ValueTask<DurableTaskWorkerDecision<TWork, TResult, TProjection>> TryClaimAsync(IDurableWorkerProjectionContract<TWork, TResult, TProjection> contract, TWork work, DurableWorkerCorrelation correlation, CancellationToken cancellationToken = default)
Attempts to claim work and maps the claim result to a Durable Task-facing decision.
contract
work
correlation
cancellationToken
A durable decision. Valid claim outcomes are claimed, already-completed, noop, stale-fence, conflict, and unrecoverable. Claimed schedules executor activity; duplicate, noop, stale, and failure outcomes do not.
ValueTask<DurableTaskWorkerDecision<TWork, TResult, TProjection>> CompleteAsync(IDurableWorkerProjectionContract<TWork, TResult, TProjection> contract, TWork work, TResult result, DurableWorkerCorrelation correlation, CancellationToken cancellationToken = default)
Records completion and maps the terminal fact to projection repair or terminal decisions.
contract
work
result
correlation
cancellationToken
A durable decision. Valid completion outcomes are completed, already-completed, noop, stale-fence, conflict, and unrecoverable. Fresh completion schedules projection repair; duplicate and noop completion do not.
ValueTask<DurableTaskWorkerDecision<TWork, TResult, TProjection>> ReconcileProjectionAsync(IDurableWorkerProjectionContract<TWork, TResult, TProjection> contract, TWork work, TResult result, DurableWorkerCorrelation correlation, CancellationToken cancellationToken = default)
Repairs projection state from a terminal fact and maps the result to a Durable Task-facing decision.
contract
work
result
correlation
cancellationToken
A durable decision. Valid projection outcomes are reconciled, noop, stale-fence, conflict, and unrecoverable. Reconciled carries a projection payload; noop completes without a projection payload; projection repair never maps to executor scheduling.
DurableTaskWorkerDecision<TWork, TResult, TProjection> WaitForExternalEvent(DurableWorkerCorrelation correlation, string eventName, FlowTimeout? timeout = null)
Creates an external-event wait decision for host-owned Durable Task orchestration code.
correlation
eventName
timeout
A wait-for-external-event decision.
DurableTaskWorkerDecision<TWork, TResult, TProjection> TimedOut(DurableWorkerCorrelation correlation, string eventName, DurableWorkerDiagnostic? diagnostic = null)
Creates a timeout decision for a wait branch that expired.
correlation
eventName
diagnostic
A timed-out decision.
DurableTaskWorkerDecision<TWork, TResult, TProjection> IgnoreLateSignal(DurableWorkerCorrelation correlation, string eventName, DurableWorkerDiagnostic? diagnostic = null)
Creates a stale or late signal decision without scheduling additional work.
correlation
eventName
diagnostic
An ignore-late-signal decision.
ArgumentException
eventName
is null, empty, or whitespace.ArgumentNullException
correlation
is null.
Default implementation of IDurableTaskWorkerChainRunner{TWork,TResult,TProjection}
.
TWork
TResult
TProjection
Registers the passive AppSurface Workers Durable Task adapter boundary.
The module depends on AppSurface Workers and Flow DurableTask, registers decision-mapping services, and leaves Durable Task worker/client hosting, storage providers, endpoints, authentication, and background services to the application.
Durable Task-facing decision produced by the worker adapter.
TWork
TResult
TProjection
Decisions are passive instructions for host-owned orchestration code. They do not schedule activities, persist state, create timers, deliver external events, or own Durable Task worker/client setup.
DurableTaskWorkerDecision<TWork, TResult, TProjection> ScheduleExecutor(DurableWorkerEnvelope<TWork> claim, FlowRetryPolicy? retryPolicy = null)
Creates an executor scheduling decision for a claimed work item.
claim
retryPolicy
A schedule-executor decision.
ArgumentException
claim
is not a claimed outcome.ArgumentNullException
claim
is null.DurableTaskWorkerDecision<TWork, TResult, TProjection> WaitForExternalEvent(DurableWorkerCorrelation correlation, string eventName, FlowTimeout? timeout = null)
Creates an external-event wait decision.
correlation
eventName
timeout
A wait-for-external-event decision.
ArgumentException
eventName
is null, empty, or whitespace.ArgumentNullException
correlation
is null.DurableTaskWorkerDecision<TWork, TResult, TProjection> RepairProjection(DurableWorkerEnvelope<TResult> completion, FlowRetryPolicy? retryPolicy = null)
Creates a projection repair scheduling decision from a completion envelope.
completion
retryPolicy
A repair-projection decision.
ArgumentException
completion
is not a completed outcome.ArgumentNullException
completion
is null.DurableTaskWorkerDecision<TWork, TResult, TProjection> Complete<TPayload>(DurableWorkerEnvelope<TPayload> envelope)
Creates a complete decision from a worker envelope without carrying a projection payload.
TPayload
envelope
A complete decision.
ArgumentNullException
envelope
is null.DurableTaskWorkerDecision<TWork, TResult, TProjection> CompleteProjection(DurableWorkerEnvelope<TProjection> envelope)
Creates a complete decision from a reconciled projection envelope.
envelope
A complete decision that carries the repaired projection.
ArgumentException
envelope
is not a reconciled outcome.ArgumentNullException
envelope
is null.DurableTaskWorkerDecision<TWork, TResult, TProjection> Fault<TPayload>(DurableWorkerEnvelope<TPayload> envelope)
Creates a fault decision from a worker envelope.
TPayload
envelope
A fault decision.
ArgumentNullException
envelope
is null.DurableTaskWorkerDecision<TWork, TResult, TProjection> IgnoreLateSignal<TPayload>(DurableWorkerEnvelope<TPayload> envelope, string? eventName = null)
Creates a late-signal decision from a worker envelope.
TPayload
envelope
eventName
An ignore-late-signal decision.
ArgumentNullException
envelope
is null.DurableTaskWorkerDecision<TWork, TResult, TProjection> WaitForRetry<TPayload>(DurableWorkerEnvelope<TPayload> envelope, FlowRetryPolicy? retryPolicy = null)
Creates a retry wait decision from a worker envelope.
TPayload
envelope
retryPolicy
A wait-for-retry decision.
ArgumentException
envelope
is not retryable.ArgumentNullException
envelope
is null.DurableTaskWorkerDecision<TWork, TResult, TProjection> TimedOut(DurableWorkerCorrelation correlation, string eventName, DurableWorkerDiagnostic? diagnostic = null)
Creates a timeout decision for a wait branch that has expired.
correlation
eventName
diagnostic
A timed-out decision.
ArgumentException
eventName
is null, empty, or whitespace.ArgumentNullException
correlation
is null.DurableTaskWorkerDecisionKind Kind { get; }
Source
Gets the decision kind.
DurableWorkerCorrelation Correlation { get; }
Source
Gets the correlation identifiers associated with the decision.
DurableWorkerDiagnostic? Diagnostic { get; }
Source
Gets optional safe diagnostic details.
TWork? Work { get; }
Source
Gets the work payload when carried by this decision.
TResult? Result { get; }
Source
Gets the terminal result payload when carried by this decision.
TProjection? Projection { get; }
Source
Gets the projection payload when carried by this decision.
string? EventName { get; }
Source
Gets the external event name for wait, timeout, or late-signal decisions.
FlowTimeout? Timeout { get; }
Source
Gets the optional timeout associated with an external event wait.
FlowRetryPolicy? RetryPolicy { get; }
Source
Gets retry intent that host orchestration code can translate into Durable Task retry options.
DurableWorkerProjectionOutcome? SourceOutcome { get; }
Source
Gets the worker contract outcome that produced the decision, when one exists.
Identifies the Durable Task-facing decision produced by the AppSurface worker adapter.
Numeric values are part of the adapter compatibility contract and may appear in durable history, tests, or telemetry. Do not reorder, remove, renumber, or reuse values.