import { InMemoryCheckpointStore } from "./checkpoint-store-memory.js"; import { CheckpointNotFoundError, ConcurrentResumeError, InvalidChannelWriteError, InvalidWorkflowConfigError, MultiWriteError, NodeExecutionError, NodeTimeoutError, PauseNotFoundError, ReducerError, ResumeWithoutSuspensionError, ThreadNotFoundError, UnknownNodeError, WorkflowAbortedError, WorkflowDivergenceError, WorkflowError, WorkflowErrorCode, WorkflowVersionMismatchError } from "./errors/index.js"; import { DispatchLike, DurabilityMode, END_NODE, EdgePredicate, NodeRunResult, PendingPauseRecord, START_NODE, StreamMode, TASKS_CHANNEL, Workflow, WorkflowConfig, WorkflowContext, WorkflowEdge, WorkflowExecuteOptions, WorkflowNode, WorkflowNodeRetryPolicy, WorkflowNodeRun, WorkflowPauseAt, WorkflowResumeOptions, WorkflowState } from "./types.js"; import { createWorkflow } from "./factory.js"; import { AwakeableRef, parseAwakeableRef, serializeAwakeableRef } from "./awakeable-ref.js"; import { ThreadCheckpointSummary, ThreadInspection, listThreadCheckpoints, readThreadState } from "./inspect.js"; import { CHECKPOINT_SCHEMA_VERSION, namespaceFor } from "./internal/engine.js"; import { createNode } from "./node.js"; import { CreateTimerDriverOptions, TickableWorkflow, TimerDriver, TimerDriverEntry, TimerDriverStatus, TimerDriverStoreUnsupportedError, createTimerDriver } from "./timer-driver.js"; import { AnyValue, ApprovalPauseValue, AwakeablePauseValue, Barrier, Channel, ChannelKind, Checkpoint, CheckpointId, CheckpointMetadata, CheckpointStore, CheckpointTuple, Directive, DirectiveOptions, Dispatch, Ephemeral, LatestValue, ListAggregate, ListOptions, PAUSE_SIGNAL_BRAND, PauseSignal, PendingWrite, Reducer, Stream, TimerPauseValue, WorkflowChannelUpdateEvent, WorkflowCheckpointWrittenEvent, WorkflowCustomEvent, WorkflowEndEvent, WorkflowErrorEvent, WorkflowEvent, WorkflowResumedEvent, WorkflowStartEvent, WorkflowStepEndEvent, WorkflowStepStartEvent, WorkflowSuspendedEvent, WorkflowTaskEndEvent, WorkflowTaskStartEvent, anyValue, awaitExternal, barrier, dispatch, ephemeral, isApprovalPauseValue, isAwakeablePauseValue, isPauseSignal, isTimerPauseValue, latestValue, listAggregate, pause, reducer, requestApproval, sleepFor, sleepUntil, stream } from "@graphorin/core"; //#region src/index.d.ts /** * `@graphorin/workflow` - step-graph workflow engine for the Graphorin * framework. * * The package owns: * * - The `createWorkflow({...})` factory and the `Workflow.execute / * resume / getState / listCheckpoints / fork` public surface. * - The synchronous-step execution loop (plan -> execute -> apply -> * checkpoint -> repeat) with deterministic per-channel write merging. * - The HITL `pause(...)` / `resume(directive)` lifecycle backed by the * pluggable `CheckpointStore` from `@graphorin/core` so paused runs * survive process restarts. * - Dynamic parallelism via `Dispatch(node, args)` returned from a * node's `run(...)` callback. * - Static `pauseAt.before` / `pauseAt.after` HITL declarations. * - The `AbortSignal`-aware hard-kill / cancellation contract with a * configurable grace window. * - Seven stream emission modes (`values`, `updates`, `messages`, * `tasks`, `checkpoints`, `debug`, `custom`) and the * `workflow.run / workflow.step / workflow.task / * workflow.checkpoint` observability spans. * - The in-memory `CheckpointStore` adapter for tests + small examples. * * The full documentation lives in the package `README.md`. * * @packageDocumentation */ declare const VERSION: string; //#endregion export { type AnyValue, type ApprovalPauseValue, type AwakeablePauseValue, type AwakeableRef, type Barrier, CHECKPOINT_SCHEMA_VERSION, type Channel, type ChannelKind, type Checkpoint, type CheckpointId, type CheckpointMetadata, CheckpointNotFoundError, type CheckpointStore, type CheckpointTuple, ConcurrentResumeError, type CreateTimerDriverOptions, Directive, type DirectiveOptions, Dispatch, type DispatchLike, type DurabilityMode, END_NODE, type EdgePredicate, type Ephemeral, InMemoryCheckpointStore, InvalidChannelWriteError, InvalidWorkflowConfigError, type LatestValue, type ListAggregate, type ListOptions, MultiWriteError, NodeExecutionError, type NodeRunResult, NodeTimeoutError, PAUSE_SIGNAL_BRAND, PauseNotFoundError, PauseSignal, type PendingPauseRecord, type PendingWrite, type Reducer, ReducerError, ResumeWithoutSuspensionError, START_NODE, type Stream, type StreamMode, TASKS_CHANNEL, type ThreadCheckpointSummary, type ThreadInspection, ThreadNotFoundError, type TickableWorkflow, type TimerDriver, type TimerDriverEntry, type TimerDriverStatus, TimerDriverStoreUnsupportedError, type TimerPauseValue, UnknownNodeError, VERSION, type Workflow, WorkflowAbortedError, type WorkflowChannelUpdateEvent, type WorkflowCheckpointWrittenEvent, type WorkflowConfig, type WorkflowContext, type WorkflowCustomEvent, WorkflowDivergenceError, type WorkflowEdge, type WorkflowEndEvent, WorkflowError, type WorkflowErrorCode, type WorkflowErrorEvent, type WorkflowEvent, type WorkflowExecuteOptions, type WorkflowNode, type WorkflowNodeRetryPolicy, type WorkflowNodeRun, type WorkflowPauseAt, type WorkflowResumeOptions, type WorkflowResumedEvent, type WorkflowStartEvent, type WorkflowState, type WorkflowStepEndEvent, type WorkflowStepStartEvent, type WorkflowSuspendedEvent, type WorkflowTaskEndEvent, type WorkflowTaskStartEvent, WorkflowVersionMismatchError, anyValue, awaitExternal, barrier, createNode, createTimerDriver, createWorkflow, dispatch, ephemeral, isApprovalPauseValue, isAwakeablePauseValue, isPauseSignal, isTimerPauseValue, latestValue, listAggregate, listThreadCheckpoints, namespaceFor, parseAwakeableRef, pause, readThreadState, reducer, requestApproval, serializeAwakeableRef, sleepFor, sleepUntil, stream }; //# sourceMappingURL=index.d.ts.map