import { K as KernelDeps } from '../plugins-6FkZgj10.js';
export { A as AnnotateAttachInput, C as CommandResult, I as IdempotencyInProgressError, J as JobExecuteCommand, a as JobExecuteResult, b as Kernel, c as KernelAnnotations, d as KernelCommand, e as KernelCommandType, f as KernelConfig, L as LeaseReapStaleCommand, g as LeaseReapStaleResult, O as OutboxFlushCommand, h as OutboxFlushResult, P as PluginDefinition, i as PluginReplayDLQCommand, j as PluginReplayDLQResult, k as PluginRunner, l as PluginRunnerConfig, R as RunCancelCommand, m as RunCancelResult, n as RunClaimPendingCommand, o as RunClaimPendingResult, p as RunCreateAnnotation, q as RunCreateCommand, r as RunCreateResult, s as RunRerunFromCommand, t as RunRerunFromResult, u as RunTransitionCommand, v as RunTransitionResult, S as StagePollSuspendedCommand, w as StagePollSuspendedResult, W as WorkflowRegistry, x as createKernel, y as createPluginRunner, z as definePlugin } from '../plugins-6FkZgj10.js';
export { K as KernelEvent, a as KernelEventType, S as StageCompletedEvent, b as StageFailedEvent, c as StageProgressEvent, d as StageStartedEvent, e as StageSuspendedEvent, W as WorkflowCancelledEvent, f as WorkflowCompletedEvent, g as WorkflowCreatedEvent, h as WorkflowFailedEvent, i as WorkflowStartedEvent, j as WorkflowSuspendedEvent } from '../events-B3XPPu0c.js';
import { A as ActivityExecutor } from '../ports-HqlAB_lY.js';
export { a as ActivityRunInput, b as ActivityRunResult, B as BlobStore, c as BufferedLog, C as Clock, E as EventSink, d as ExecutorDeps, J as JobTransport, P as Persistence, S as Scheduler } from '../ports-HqlAB_lY.js';
export { i as AnnotationActor, A as AnnotationFilters, v as AnnotationScope, f as CreateAnnotationInput, h as CreateOutboxEventInput, I as IdempotencyRecord, O as OutboxRecord, g as WorkflowAnnotationRecord } from '../interface-DMzwv0lD.js';
import 'zod';
import '../stage-DHgQdIcT.js';
import '../types-ByGg__Kd.js';

/**
 * LocalExecutor — default ActivityExecutor implementation.
 *
 * Runs stage execute() in the current process. This is an exact extraction
 * of the Phase-2 body from handlers/job-execute.ts; behavior is byte-for-byte
 * identical to the pre-refactor handler.
 *
 * Logs are written live (fire-and-forget createLog) during execution, so
 * this executor returns logs: [] — the handler does not need to persist them.
 */

declare function createLocalExecutor(): ActivityExecutor;

/**
 * RoutingExecutor — per-stage ActivityExecutor routing.
 *
 * Routes specific stage IDs to a remote executor, all others to a local
 * executor (defaults to createLocalExecutor()). This enables a mixed model:
 * heavy/expensive stages run on remote workers, lightweight stages run
 * in-process without the overhead of a round-trip.
 */

interface RoutingExecutorOptions {
    /** Executor used for stage IDs listed in remoteStageIds. */
    remote: ActivityExecutor;
    /** Stage IDs that should be routed to the remote executor. */
    remoteStageIds: ReadonlyArray<string>;
    /**
     * Executor used for all other stage IDs.
     * Defaults to createLocalExecutor() — lazily created on first use.
     */
    local?: ActivityExecutor;
}
declare function createRoutingExecutor(opts: RoutingExecutorOptions): ActivityExecutor;

/**
 * Load workflow context from completed stages.
 *
 * For each completed stage, loads the output from BlobStore using
 * the _artifactKey stored in stage.outputData.
 */

declare function loadWorkflowContext(workflowRunId: string, deps: KernelDeps): Promise<Record<string, unknown>>;

/**
 * Save stage output to BlobStore and return the blob key.
 *
 * The key is stored in stage.outputData._artifactKey so that
 * loadWorkflowContext() can retrieve it later.
 */

declare function saveStageOutput(runId: string, workflowType: string, stageId: string, output: unknown, deps: KernelDeps): Promise<string>;

export { ActivityExecutor, type RoutingExecutorOptions, createLocalExecutor, createRoutingExecutor, loadWorkflowContext, saveStageOutput };