From 1b8797ad4741844b6c0a480343f62cfacd3eeba3 Mon Sep 17 00:00:00 2001 From: Roman Snapko Date: Fri, 13 Mar 2026 15:39:15 +0100 Subject: [PATCH] Handle internal errors in trigger payload extraction --- .../trigger/hooks/extract-trigger-payload-hooks.ts | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/packages/server/worker/src/lib/trigger/hooks/extract-trigger-payload-hooks.ts b/packages/server/worker/src/lib/trigger/hooks/extract-trigger-payload-hooks.ts index a205e1d4c4..0b30f31cdc 100644 --- a/packages/server/worker/src/lib/trigger/hooks/extract-trigger-payload-hooks.ts +++ b/packages/server/worker/src/lib/trigger/hooks/extract-trigger-payload-hooks.ts @@ -38,6 +38,19 @@ export async function extractPayloads( handleFailureFlow(flowVersion, projectId, engineToken, true); return result.output as unknown[]; } else { + if ('status' in result && result.status === 'INTERNAL_ERROR') { + logger.warn( + { + result, + blockName, + blockVersion, + flowId: flowVersion.flowId, + }, + 'Failed to execute trigger because of internal error in the engine', + ); + return []; + } + logger.error( { result,