diff --git a/src/core/workflow/WorkflowEngine.ts b/src/core/workflow/WorkflowEngine.ts index 17e079d..bdf73d6 100644 --- a/src/core/workflow/WorkflowEngine.ts +++ b/src/core/workflow/WorkflowEngine.ts @@ -144,6 +144,10 @@ export class WorkflowEngine { context: NodeContext, timeout?: number ): Promise { + if (typeof handler !== 'function') { + throw new Error('Invalid node handler: expected function'); + } + if (!timeout) { return handler(node, context); }