import { RequestContext } from '../../di/index.js'; import type { SerializedError } from '../../error/index.js'; import type { PubSub } from '../../events/pubsub.js'; import type { ObservabilityContext } from '../../observability/index.js'; import type { DefaultExecutionEngine } from '../default.js'; import type { EntryExecutionResult, ExecutionContext, OutputWriter, RestartExecutionParams, SerializedStepFlowEntry, StepFlowEntry, StepResult, TimeTravelExecutionParams, WorkflowRunStatus } from '../types.js'; export interface PersistStepUpdateParams { workflowId: string; runId: string; resourceId?: string; stepResults: Record>; serializedStepGraph: SerializedStepFlowEntry[]; executionContext: ExecutionContext; workflowStatus: WorkflowRunStatus; result?: Record; error?: SerializedError; requestContext: RequestContext; /** * Tracing context for span continuity during suspend/resume. * When provided, this will be persisted to the snapshot for use on resume. */ tracingContext?: { traceId?: string; spanId?: string; parentSpanId?: string; }; } export declare function persistStepUpdate(engine: DefaultExecutionEngine, params: PersistStepUpdateParams): Promise; export interface ExecuteEntryParams extends ObservabilityContext { workflowId: string; runId: string; resourceId?: string; entry: StepFlowEntry; prevStep: StepFlowEntry; serializedStepGraph: SerializedStepFlowEntry[]; stepResults: Record>; restart?: RestartExecutionParams; timeTravel?: TimeTravelExecutionParams; resume?: { steps: string[]; stepResults: Record>; resumePayload: any; resumePath: number[]; }; executionContext: ExecutionContext; pubsub: PubSub; abortController: AbortController; requestContext: RequestContext; outputWriter?: OutputWriter; disableScorers?: boolean; perStep?: boolean; } export declare function executeEntry(engine: DefaultExecutionEngine, params: ExecuteEntryParams): Promise; //# sourceMappingURL=entry.d.ts.map