Skip to content

Graphorin API reference v0.1.0


Graphorin API reference / @graphorin/workflow / / Workflow

Interface: Workflow<TState, TInput>

Defined in: packages/workflow/src/types.ts:303

Top-level handle returned by createWorkflow.

Stable

Type Parameters

Type ParameterDefault type
TState extends objectRecord<string, unknown>
TInputPartial<TState>

Properties

PropertyModifierTypeDefined in
namereadonlystringpackages/workflow/src/types.ts:307
nodeNamesreadonlyreadonly string[]packages/workflow/src/types.ts:308

Methods

execute()

ts
execute(input, opts?): AsyncIterable<WorkflowEvent<TState>>;

Defined in: packages/workflow/src/types.ts:309

Parameters

ParameterType
inputTInput
opts?WorkflowExecuteOptions

Returns

AsyncIterable<WorkflowEvent&lt;TState&gt;>


fork()

ts
fork(threadId, fromCheckpointId): Promise<{
  newThreadId: string;
}>;

Defined in: packages/workflow/src/types.ts:317

Parameters

ParameterType
threadIdstring
fromCheckpointIdstring

Returns

Promise<{ newThreadId: string; }>


getState()

ts
getState(threadId): Promise<WorkflowState<TState>>;

Defined in: packages/workflow/src/types.ts:315

Parameters

ParameterType
threadIdstring

Returns

Promise<WorkflowState&lt;TState&gt;>


listCheckpoints()

ts
listCheckpoints(threadId): Promise<readonly Checkpoint[]>;

Defined in: packages/workflow/src/types.ts:316

Parameters

ParameterType
threadIdstring

Returns

Promise&lt;readonly Checkpoint[]&gt;


resume()

ts
resume(
   threadId, 
   directive?, 
opts?): AsyncIterable<WorkflowEvent<TState>>;

Defined in: packages/workflow/src/types.ts:310

Parameters

ParameterType
threadIdstring
directive?Directive<Record&lt;string, unknown&gt;, unknown>
opts?WorkflowResumeOptions

Returns

AsyncIterable<WorkflowEvent&lt;TState&gt;>