fix(executor): emit finalBlockLogs on queued/HITL error and cancel paths

queued-workflow-execution and human-in-the-loop-manager only attached
finalBlockLogs to execution:completed. Without it on cancel/error,
reconcileFinalBlockLogs is a no-op and the client sweep flips
already-completed blocks to canceled. Mirror the route.ts pattern.

Author: waleedlatif1

apps/sim/lib/workflows/executor/human-in-the-loop-manager.ts

@@ -23,6 +23,7 @@ import type {
   SerializedSnapshot,
   StreamingExecution,
 } from '@/executor/types'
+import { hasExecutionResult } from '@/executor/utils/errors'
 import { filterOutputForLog } from '@/executor/utils/output-filter'
 import type { SerializedConnection } from '@/serializer/types'
 
@@ -1039,6 +1040,7 @@ export class PauseResumeManager {
           data: {
             error: timeoutErrorMessage,
             duration: result.metadata?.duration || 0,
+            finalBlockLogs: result.logs,
           },
         } as ExecutionEvent)
         finalMetaStatus = 'error'
@@ -1048,7 +1050,10 @@ export class PauseResumeManager {
           timestamp: new Date().toISOString(),
           executionId: resumeExecutionId,
           workflowId,
-          data: { duration: result.metadata?.duration || 0 },
+          data: {
+            duration: result.metadata?.duration || 0,
+            finalBlockLogs: result.logs,
+          },
         } as ExecutionEvent)
         finalMetaStatus = 'cancelled'
       } else if (result.status === 'paused') {
@@ -1083,6 +1088,7 @@ export class PauseResumeManager {
         finalMetaStatus = 'complete'
       }
     } catch (execError) {
+      const execErrorResult = hasExecutionResult(execError) ? execError.executionResult : undefined
       writeBufferedEvent({
         type: 'execution:error',
         timestamp: new Date().toISOString(),
@@ -1091,6 +1097,7 @@ export class PauseResumeManager {
         data: {
           error: toError(execError).message,
           duration: 0,
+          finalBlockLogs: execErrorResult?.logs,
         },
       } as ExecutionEvent)
       finalMetaStatus = 'error'

apps/sim/lib/workflows/executor/queued-workflow-execution.ts

@@ -169,6 +169,7 @@ export async function executeQueuedWorkflowJob(
           data: {
             error: timeoutErrorMessage,
             duration: result.metadata?.duration || 0,
+            finalBlockLogs: result.logs,
           },
         })
 
@@ -214,6 +215,7 @@ export async function executeQueuedWorkflowJob(
           workflowId,
           data: {
             duration: result.metadata?.duration || 0,
+            finalBlockLogs: result.logs,
           },
         })
         await setExecutionMeta(executionId, { status: 'cancelled' })
@@ -290,6 +292,8 @@ export async function executeQueuedWorkflowJob(
       })
     }
 
+    const executionResult = hasExecutionResult(error) ? error.executionResult : undefined
+
     if (eventWriter) {
       await eventWriter.write({
         type: 'execution:error',
@@ -299,13 +303,12 @@ export async function executeQueuedWorkflowJob(
         data: {
           error: toError(error).message,
           duration: 0,
+          finalBlockLogs: executionResult?.logs,
         },
       })
       await setExecutionMeta(executionId, { status: 'error' })
     }
 
-    const executionResult = hasExecutionResult(error) ? error.executionResult : undefined
-
     return buildResult(
       'failed',
       {