import { $t as RunId, F as RunStatus, Ii as CredentialRequirement, Nt as NodeActivationId, Qi as NodeId, S as PersistedWorkflowSnapshot, _ as PersistedMutableRunState, bt as BinaryAttachment, cn as WorkflowDefinition, f as NodeExecutionStatus, jt as JsonValue, kt as JsonObject, n as AgentMcpToolMap, t as AgentMcpIntegration, ta as WorkflowId, u as NodeExecutionError } from "./agentMcpTypes-BHX4RQCC.cjs"; //#region src/contracts/dispatchTypes.d.ts type WorkspaceId = string; type DispatchBinaryRef = BinaryAttachment; interface DispatchItemMeta { readonly id: string; readonly json?: JsonValue; readonly binary?: Readonly>; } interface WorkflowDispatch { readonly runId: RunId; readonly workspaceId: WorkspaceId; readonly workflowId: WorkflowId; readonly triggerNodeId: NodeId; readonly items: ReadonlyArray; readonly triggerContext: JsonValue; } declare function serializeDispatch(dispatch: WorkflowDispatch): string; declare function deserializeDispatch(raw: string): WorkflowDispatch; //#endregion //#region src/contracts/AgentBindError.d.ts declare class AgentBindError extends Error { constructor(message: string); } //#endregion //#region src/contracts/NoOpAgentMcpIntegration.d.ts declare class NoOpAgentMcpIntegration implements AgentMcpIntegration { prepareMcpTools(): Promise; } //#endregion //#region src/contracts/assertionTypes.d.ts interface AssertionResult { readonly name: string; readonly score: number; readonly passThreshold?: number; readonly errored?: true; readonly expected?: JsonValue; readonly actual?: JsonValue; readonly message?: string; readonly details?: Readonly>; } declare const DEFAULT_ASSERTION_PASS_THRESHOLD = 0.5; declare function deriveAssertionPassed(result: { readonly score: number; readonly passThreshold?: number; readonly errored?: true; }): boolean; interface AssertionResultProvenance { readonly nodeId: NodeId; readonly iterationId?: string; readonly itemIndex?: number; } //#endregion //#region src/contracts/executionPersistenceContracts.d.ts type ExecutionInstanceId = string; type WorkItemId = string; type BatchId = string; type RunRevision = number; type PersistedRunWorkItemKind = "queue" | "pending"; type WorkItemStatus = "queued" | "claimed" | "completed" | "failed" | "cancelled"; type PersistedExecutionInstanceKind = "workflowNodeActivation" | "connectionInvocation"; type ConnectionInvocationKind = "languageModel" | "tool" | "nestedAgent"; type PayloadStorageKind = "inline" | "external" | "omitted"; interface PersistedRunWorkItemRecord { readonly workItemId: WorkItemId; readonly runId: RunId; readonly workflowId: WorkflowId; readonly kind: PersistedRunWorkItemKind; readonly orderIndex: number; readonly status: WorkItemStatus; readonly queueName?: string; readonly claimToken?: string; readonly claimedBy?: string; readonly claimedAt?: string; readonly availableAt: string; readonly enqueuedAt: string; readonly completedAt?: string; readonly failedAt?: string; readonly sourceInstanceId?: ExecutionInstanceId; readonly parentInstanceId?: ExecutionInstanceId; readonly itemsIn: number; readonly payloadJson: string; readonly error?: Readonly; } interface ExecutionPayloadPolicyFields { readonly inputStorageKind: PayloadStorageKind; readonly outputStorageKind: PayloadStorageKind; readonly inputBytes?: number; readonly outputBytes?: number; readonly inputPreviewJson?: unknown; readonly outputPreviewJson?: unknown; readonly inputPayloadRef?: string; readonly outputPayloadRef?: string; readonly inputTruncated?: boolean; readonly outputTruncated?: boolean; } interface PersistedExecutionInstanceRecord { readonly instanceId: ExecutionInstanceId; readonly runId: RunId; readonly workflowId: WorkflowId; readonly slotNodeId: NodeId; readonly workflowNodeId: NodeId; readonly kind: PersistedExecutionInstanceKind; readonly connectionKind?: ConnectionInvocationKind; readonly activationId?: NodeActivationId; readonly batchId: BatchId; readonly runIndex: number; readonly parentInstanceId?: ExecutionInstanceId; readonly parentRunId?: RunId; readonly workerClaimToken?: string; readonly status: NodeExecutionStatus; readonly queuedAt?: string; readonly startedAt?: string; readonly finishedAt?: string; readonly updatedAt: string; readonly itemCount: number; readonly inputJson?: string; readonly outputJson?: string; readonly errorJson?: string; readonly inputItemIndicesJson?: string; readonly outputItemCount?: number; readonly successfulItemCount?: number; readonly failedItemCount?: number; readonly truncatedInputPreviewJson?: string; readonly truncatedOutputPreviewJson?: string; readonly inputTruncated?: boolean; readonly outputTruncated?: boolean; readonly usedPinnedOutput?: boolean; readonly payloadPolicy?: ExecutionPayloadPolicyFields; } interface RunSlotProjectionState { readonly runId: RunId; readonly workflowId: WorkflowId; readonly revision: RunRevision; readonly slotStatesByNodeId: Record>; } interface PersistedRunSlotProjectionRecord { readonly runId: RunId; readonly workflowId: WorkflowId; readonly revision: RunRevision; readonly updatedAt: string; readonly slotStatesJson: string; } interface WorkflowRunDetailDto { readonly runId: RunId; readonly workflowId: WorkflowId; readonly startedAt: string; readonly finishedAt?: string; readonly status: RunStatus; readonly workflowSnapshot?: PersistedWorkflowSnapshot; readonly mutableState?: PersistedMutableRunState; readonly slotStates: ReadonlyArray; readonly executionInstances: ReadonlyArray; readonly iterations?: ReadonlyArray; } interface RunIterationDto { readonly iterationId: string; readonly agentNodeId: NodeId; readonly activationId: NodeActivationId; readonly itemIndex: number; readonly itemSummary?: string; readonly status: NodeExecutionStatus; readonly startedAt?: string; readonly finishedAt?: string; readonly invocationIds: ReadonlyArray; readonly parentInvocationId?: string; readonly estimatedCostMinorByCurrency?: Readonly>; readonly estimatedCostCurrencyScaleByCurrency?: Readonly>; } interface SlotExecutionStateDto { readonly slotNodeId: NodeId; readonly latestInstanceId?: ExecutionInstanceId; readonly latestTerminalInstanceId?: ExecutionInstanceId; readonly latestRunningInstanceId?: ExecutionInstanceId; readonly status?: NodeExecutionStatus; readonly invocationCount: number; readonly runCount: number; } interface ExecutionInstanceDto { readonly instanceId: ExecutionInstanceId; readonly slotNodeId: NodeId; readonly workflowNodeId: NodeId; readonly parentInstanceId?: ExecutionInstanceId; readonly kind: PersistedExecutionInstanceKind; readonly connectionKind?: ConnectionInvocationKind; readonly runIndex: number; readonly batchId: BatchId; readonly activationId?: NodeActivationId; readonly status: NodeExecutionStatus; readonly queuedAt?: string; readonly startedAt?: string; readonly finishedAt?: string; readonly itemCount: number; readonly inputJson?: JsonValue; readonly outputJson?: JsonValue; readonly error?: Readonly; readonly iterationId?: string; readonly itemIndex?: number; readonly parentInvocationId?: string; readonly childRunId?: string; } interface WorkflowDetailSelectionState { readonly selectedSlotNodeId: NodeId | null; readonly selectedInstanceId: ExecutionInstanceId | null; } //#endregion //#region src/contracts/deploymentManifestTypes.d.ts declare const DEPLOYMENT_MANIFEST_SCHEMA_VERSION: 2; type DeploymentManifestSchemaVersion = typeof DEPLOYMENT_MANIFEST_SCHEMA_VERSION; type ManifestTriggerConfig = Readonly<{ nodeId: NodeId; triggerKind: "live" | "test"; config: JsonObject; pollIntervalMs?: number; nodeTypeId?: string; }>; type ManifestNodeCredentialShape = Readonly<{ nodeId: NodeId; requirements: ReadonlyArray; }>; type WorkflowDeploymentManifest = Readonly<{ manifestId: string; schemaVersion: DeploymentManifestSchemaVersion; workflowId: WorkflowId; canvas: TCanvas; snapshot: PersistedWorkflowSnapshot; triggers: ReadonlyArray; credentialShapes: ReadonlyArray; }>; declare function serializeManifest(manifest: WorkflowDeploymentManifest): string; declare function deserializeManifest(raw: string): WorkflowDeploymentManifest; type ManifestCanvasNode = Readonly<{ id: NodeId; kind: string; name: string | undefined; type?: string; role?: string; triggerKind?: "live" | "test"; declaredOutputPorts?: ReadonlyArray; declaredInputPorts?: ReadonlyArray; }>; type ManifestCanvas = Readonly<{ id: WorkflowId; name: string; nodes: ReadonlyArray; edges: WorkflowDefinition["edges"]; }>; declare function emitWorkflowManifest(workflow: WorkflowDefinition): WorkflowDeploymentManifest; //#endregion export { DEFAULT_ASSERTION_PASS_THRESHOLD as A, SlotExecutionStateDto as C, WorkflowRunDetailDto as D, WorkflowDetailSelectionState as E, WorkflowDispatch as F, WorkspaceId as I, deserializeDispatch as L, NoOpAgentMcpIntegration as M, AgentBindError as N, AssertionResult as O, DispatchItemMeta as P, serializeDispatch as R, RunSlotProjectionState as S, WorkItemStatus as T, PersistedRunSlotProjectionRecord as _, WorkflowDeploymentManifest as a, RunIterationDto as b, serializeManifest as c, ExecutionInstanceDto as d, ExecutionInstanceId as f, PersistedExecutionInstanceRecord as g, PersistedExecutionInstanceKind as h, ManifestTriggerConfig as i, deriveAssertionPassed as j, AssertionResultProvenance as k, BatchId as l, PayloadStorageKind as m, DeploymentManifestSchemaVersion as n, deserializeManifest as o, ExecutionPayloadPolicyFields as p, ManifestNodeCredentialShape as r, emitWorkflowManifest as s, DEPLOYMENT_MANIFEST_SCHEMA_VERSION as t, ConnectionInvocationKind as u, PersistedRunWorkItemKind as v, WorkItemId as w, RunRevision as x, PersistedRunWorkItemRecord as y }; //# sourceMappingURL=deploymentManifestTypes-B8CDmZZK.d.cts.map