import type { ExecutorResult, Loop, LoopRun, StoredWorkflowEvent, WorkflowRun, WorkflowRunStatus, WorkflowSpec, WorkflowStepRun } from "../types.js";
import { preflightTarget, type ExecuteOptions } from "./executor.js";
import type { CreateWorkflowRunInput, WorkflowRecoveryContext } from "./store.js";
import type { GoalRunnerStore } from "./goal/runner.js";
import { type OperationReceiptState, type PrivateOperationDescriptor } from "./operation-contract.js";
export interface ExecuteWorkflowOptions extends ExecuteOptions {
    loop?: Loop;
    loopRun?: LoopRun;
    scheduledFor?: string;
    idempotencyKey?: string;
    cancelPollMs?: number;
    signalTimeoutMessage?: () => string | undefined;
    /** Per-node goal prompt appended to agent step prompts when a goal executes this workflow. */
    goalNodePrompt?: string;
}
type MaybePromise<T> = T | Promise<T>;
export interface WorkflowExecutionStore extends GoalRunnerStore {
    /** Hosted runners receive server-derived contract events and must not append client-authored copies. */
    readonly serverDerivedAgentSessionContracts?: boolean;
    requireWorkflow(idOrName: string): MaybePromise<WorkflowSpec>;
    createWorkflowRun(input: CreateWorkflowRunInput): MaybePromise<WorkflowRun>;
    getWorkflowRun(id: string): MaybePromise<WorkflowRun | undefined>;
    requireWorkflowRun(id: string): MaybePromise<WorkflowRun>;
    listWorkflowStepRuns(workflowRunId: string): MaybePromise<WorkflowStepRun[]>;
    getWorkflowStepRun(workflowRunId: string, stepId: string): MaybePromise<WorkflowStepRun | undefined>;
    isWorkflowRunTerminal(workflowRunId: string): MaybePromise<boolean>;
    startWorkflowStepRun(workflowRunId: string, stepId: string, opts?: {
        daemonLeaseId?: string;
        now?: Date;
    }): MaybePromise<WorkflowStepRun>;
    recoverWorkflowRun(workflowRunId: string, reason?: string, context?: WorkflowRecoveryContext): MaybePromise<{
        run: WorkflowRun;
        recoveredSteps: WorkflowStepRun[];
    }>;
    finalizeWorkflowStepRun(workflowRunId: string, stepId: string, patch: Pick<WorkflowStepRun, "status" | "finishedAt" | "durationMs" | "stdout" | "stderr"> & Partial<Pick<WorkflowStepRun, "exitCode" | "error">>, opts?: {
        daemonLeaseId?: string;
        now?: Date;
    }): MaybePromise<WorkflowStepRun>;
    finalizeWorkflowRun(workflowRunId: string, status: WorkflowRunStatus, patch?: Partial<Pick<WorkflowRun, "finishedAt" | "durationMs" | "error">>, opts?: {
        daemonLeaseId?: string;
        now?: Date;
    }): MaybePromise<WorkflowRun>;
    markWorkflowStepPid(workflowRunId: string, stepId: string, pid: number, opts?: {
        daemonLeaseId?: string;
        now?: Date;
    }): MaybePromise<WorkflowStepRun>;
    recordWorkflowStepProgress(workflowRunId: string, stepId: string, progress: {
        stdout?: string;
        stderr?: string;
        payload?: Record<string, unknown>;
    }, opts?: {
        daemonLeaseId?: string;
        now?: Date;
    }): MaybePromise<WorkflowStepRun>;
    appendWorkflowEvent(workflowRunId: string, eventType: string, stepId?: string, payload?: Record<string, unknown>): MaybePromise<unknown>;
    listWorkflowEvents?(workflowRunId: string, limit?: number): MaybePromise<StoredWorkflowEvent[]>;
    getPrivateOperationDescriptor?(workflowRunId: string, stepId: string): MaybePromise<PrivateOperationDescriptor>;
    getPrivateOperationState?(workflowRunId: string, stepId: string): MaybePromise<OperationReceiptState>;
    skipWorkflowStepRun(workflowRunId: string, stepId: string, reason: string, opts?: {
        daemonLeaseId?: string;
        now?: Date;
    }): MaybePromise<WorkflowStepRun>;
}
export declare function executeWorkflow(store: WorkflowExecutionStore, workflow: WorkflowSpec, opts?: ExecuteWorkflowOptions): Promise<ExecutorResult>;
export declare function preflightWorkflow(workflow: WorkflowSpec, opts?: ExecuteOptions): ReturnType<typeof preflightTarget>[];
export declare function executeLoopTarget(store: WorkflowExecutionStore, loop: Loop, run: LoopRun, opts?: ExecuteOptions): Promise<ExecutorResult>;
export {};