/** * Compatibility adapter for the historical graph executor API. * Graph configs now compile to WorkflowIR and execute through the single * Effect-native workflow executor. */ import { Context, Effect, Layer } from 'effect'; import type { AgentResponse } from '../agent/agent'; import type { PipelineContext } from './context'; import type { AgentManagerLike, ExecutorOptions, HookManagerLike } from './executor'; import type { BranchCondition, GraphEdge, GraphWorkflowConfig } from './graph'; import type { Tracer } from '../tracing'; export interface GraphExecutionResult { success: boolean; context: PipelineContext; outputs: Record; executedNodes: string[]; error?: Error; abortedBy?: string; } export type GraphExecutionError = Error; export interface GraphExecutorOptions extends ExecutorOptions { conversationId?: string; agentManager: AgentManagerLike; hookManager?: HookManagerLike; tracer?: Tracer; pipelineManager?: { getPipeline: (id: string) => { execute: (input: unknown) => Promise; } | undefined; }; } export interface GraphExecutorService { executeGraphWorkflow(config: GraphWorkflowConfig, input: string, options: GraphExecutorOptions): Effect.Effect; } export declare const GraphExecutorService: Context.Tag; export declare function evaluateCondition(condition: BranchCondition, context: PipelineContext): boolean; export declare function selectNextNodes(currentNode: string, edges: GraphEdge[], context: PipelineContext): string[]; export declare function executeGraphWorkflowEffect(config: GraphWorkflowConfig, input: string, options: GraphExecutorOptions): Effect.Effect; export declare const GraphExecutorServiceLive: Layer.Layer; //# sourceMappingURL=graph-executor.d.ts.map