fix(executor): reconcile finalBlockLogs on execution:completed

block:completed callbacks fire-and-forget; the last block's event can
arrive after execution:completed, leaving its console entry stuck
isRunning. Mirror the error/cancelled paths: emit finalBlockLogs on
execution:completed and reconcile + sweep on the client.

Author: waleedlatif1

apps/sim/app/api/workflows/[id]/execute/route.ts

@@ -1220,6 +1220,7 @@ async function handleExecutePost(
                 duration: result.metadata?.duration || 0,
                 startTime: result.metadata?.startTime || startTime.toISOString(),
                 endTime: result.metadata?.endTime || new Date().toISOString(),
+                finalBlockLogs: result.logs,
               },
             })
           }

apps/sim/app/workspace/[workspaceId]/w/[workflowId]/hooks/use-workflow-execution.ts

@@ -25,6 +25,7 @@ import {
   addHttpErrorConsoleEntry,
   type BlockEventHandlerConfig,
   createBlockEventHandlers,
+  reconcileFinalBlockLogs,
   addExecutionErrorConsoleEntry as sharedAddExecutionErrorConsoleEntry,
   handleExecutionCancelledConsole as sharedHandleExecutionCancelledConsole,
   handleExecutionErrorConsole as sharedHandleExecutionErrorConsole,
@@ -1130,6 +1131,13 @@ export function useWorkflowExecution() {
 
               if (activeWorkflowId) {
                 setCurrentExecutionId(activeWorkflowId, null)
+                reconcileFinalBlockLogs(
+                  updateConsole,
+                  activeWorkflowId,
+                  executionIdRef.current,
+                  data.finalBlockLogs
+                )
+                cancelRunningEntries(activeWorkflowId)
               }
 
               executionResult = {
@@ -1702,6 +1710,14 @@ export function useWorkflowExecution() {
             onBlockChildWorkflowStarted: blockHandlers.onBlockChildWorkflowStarted,
 
             onExecutionCompleted: (data) => {
+              reconcileFinalBlockLogs(
+                updateConsole,
+                workflowId,
+                executionIdRef.current,
+                data.finalBlockLogs
+              )
+              cancelRunningEntries(workflowId)
+
               if (data.success) {
                 executedBlockIds.add(blockId)
 
@@ -1980,7 +1996,7 @@ export function useWorkflowExecution() {
               onBlockCompleted: wrapHandler(handlers.onBlockCompleted),
               onBlockError: wrapHandler(handlers.onBlockError),
               onBlockChildWorkflowStarted: wrapHandler(handlers.onBlockChildWorkflowStarted),
-              onExecutionCompleted: () => {
+              onExecutionCompleted: (data) => {
                 reconnectionComplete = true
                 activeReconnections.delete(reconnectWorkflowId)
                 if (!activated) {
@@ -1994,6 +2010,13 @@ export function useWorkflowExecution() {
                 setCurrentExecutionId(reconnectWorkflowId, null)
                 setIsExecuting(reconnectWorkflowId, false)
                 setActiveBlocks(reconnectWorkflowId, new Set())
+                reconcileFinalBlockLogs(
+                  updateConsole,
+                  reconnectWorkflowId,
+                  capturedExecutionId,
+                  data?.finalBlockLogs
+                )
+                cancelRunningEntries(reconnectWorkflowId)
               },
               onExecutionError: (data) => {
                 reconnectionComplete = true

apps/sim/app/workspace/[workspaceId]/w/[workflowId]/utils/workflow-execution-utils.ts

@@ -731,6 +731,8 @@ export async function executeWorkflowWithFullLogging(
 
         onExecutionCompleted: (data) => {
           setCurrentExecutionId(wfId, null)
+          reconcileFinalBlockLogs(updateConsole, wfId, executionIdRef.current, data.finalBlockLogs)
+          cancelRunningEntries(wfId)
           executionResult = {
             success: data.success,
             output: data.output,

apps/sim/lib/workflows/executor/execution-events.ts

@@ -52,6 +52,8 @@ export interface ExecutionCompletedEvent extends BaseExecutionEvent {
     duration: number
     startTime: string
     endTime: string
+    /** Authoritative per-block terminal states from the server's blockLogs. */
+    finalBlockLogs?: BlockLog[]
   }
 }
 

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

@@ -1077,6 +1077,7 @@ export class PauseResumeManager {
             duration: result.metadata?.duration || 0,
             startTime: result.metadata?.startTime || new Date().toISOString(),
             endTime: result.metadata?.endTime || new Date().toISOString(),
+            finalBlockLogs: result.logs,
           },
         } as ExecutionEvent)
         finalMetaStatus = 'complete'

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

@@ -243,6 +243,7 @@ export async function executeQueuedWorkflowJob(
             duration: result.metadata?.duration || 0,
             startTime: result.metadata?.startTime || metadata.startTime,
             endTime: result.metadata?.endTime || new Date().toISOString(),
+            finalBlockLogs: result.logs,
           },
         })
         await setExecutionMeta(executionId, { status: 'complete' })