Interface IRunTimeoutEnforcer
- Namespace
- FlowOrchestrator.Core.Execution
- Assembly
- FlowOrchestrator.Core.dll
Proactively enforces run-level timeout deadlines. Implemented by FlowOrchestratorEngine
and driven by the periodic FlowTimeoutEnforcementHostedService.
public interface IRunTimeoutEnforcer
Remarks
Separated from IFlowOrchestrator so the hosted service can depend on just the enforcement entry point without coupling to the full orchestration surface, and so runtime shims are unaffected.
Methods
EnforceDueTimeoutsAsync(CancellationToken)
Scans every active run and marks those whose timeout deadline has already passed as
TimedOut, completing the run when no step is still in flight.
Task EnforceDueTimeoutsAsync(CancellationToken cancellationToken = default)
Parameters
cancellationTokenCancellationTokenToken that aborts the sweep between runs.
Returns
Remarks
A no-op when no IFlowRunControlStore is registered. Runs with an
in-flight step are latched TimedOut but not force-completed — the in-flight guard in
run completion converges the run once the step finishes.