Class WorkflowOrchestratorAdapter

constructor

• new WorkflowOrchestratorAdapter(
      engine: IWorkflowEngine,
      logger?: ILogger,
  ): WorkflowOrchestratorAdapter

  Parameters

  • engine: IWorkflowEngine
  • Optionallogger: ILogger

  Returns WorkflowOrchestratorAdapter

Readonlyid

Readonlytype

execute

• execute(
      definition: OrchestratorDefinition,
      inputs: Record<string, unknown>,
      _options?: OrchestratorExecuteOptions,
  ): Promise<Result<OrchestratorResult, OrchestratorError>>

  Execute an orchestration.

  Parameters

  • definition: OrchestratorDefinition

    What to orchestrate (task, workflow, or policy)

  • inputs: Record<string, unknown>

    Input values for the orchestration

  • Optional_options: OrchestratorExecuteOptions

  Returns Promise<Result<OrchestratorResult, OrchestratorError>>

  Result with OrchestratorResult or OrchestratorError

getStatus

• getStatus(executionId: string): ExecutionStatus

  Get status of an execution.

  Parameters

  • executionId: string

    Execution ID to check

  Returns ExecutionStatus

  Current execution status

cancel

• cancel(
      executionId: string,
      reason?: string,
  ): Promise<Result<void, OrchestratorError>>

  Cancel a running execution.

  Parameters

  • executionId: string

    Execution ID to cancel

  • Optionalreason: string

    Optional cancellation reason

  Returns Promise<Result<void, OrchestratorError>>

  Result with void or OrchestratorError

getHistory

• getHistory(limit?: number): OrchestratorResult[]

  Get execution history. Optional - for orchestrators that track history.

  Parameters

  • Optionallimit: number

    Maximum number of executions to return

  Returns OrchestratorResult[]

  Array of past execution results