Interface ITaskMiddlewareExecutionInput<TTaskInput, TTaskOutput>

Input object passed to task middleware run(...).

interface ITaskMiddlewareExecutionInput<TTaskInput = any, TTaskOutput = any> {
    journal: ExecutionJournal;
    next: (taskInput?: TTaskInput) => Promise<TTaskOutput>;
    task: { definition: ITask<TTaskInput, any, any, any>; input: TTaskInput };
}

Type Parameters

TTaskInput = any
TTaskOutput = any

Index

Properties

journal next task

Properties

journal

journal: ExecutionJournal

Per-execution registry for sharing state between middleware and task

next

next: (taskInput?: TTaskInput) => Promise<TTaskOutput>

Continues execution, optionally overriding the task input.

task

task: { definition: ITask<TTaskInput, any, any, any>; input: TTaskInput }

Current task definition and input being processed.