fix(terminal): correct error/cancel block status in logs panel

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

@@ -1165,6 +1165,7 @@ async function handleExecutePost(
  data: {
  error: timeoutErrorMessage,
  duration: result.metadata?.duration || 0,
+ finalBlockLogs: result.logs,
  },
  })
  finalMetaStatus = 'error'
@@ -1178,6 +1179,7 @@ async function handleExecutePost(
  workflowId,
  data: {
  duration: result.metadata?.duration || 0,
+ finalBlockLogs: result.logs,
  },
  })
  finalMetaStatus = 'cancelled'
@@ -1242,6 +1244,7 @@ async function handleExecutePost(
  data: {
  error: executionResult?.error || errorMessage,
  duration: executionResult?.metadata?.duration || 0,
+ finalBlockLogs: executionResult?.logs,
  },
  })
  finalMetaStatus = 'error'

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

@@ -216,25 +216,31 @@ export function useWorkflowExecution() {
  durationMs?: number
  blockLogs: BlockLog[]
  isPreExecutionError?: boolean
+ finalBlockLogs?: BlockLog[]
  }) => {
  if (!params.workflowId) return
- sharedHandleExecutionErrorConsole(addConsole, cancelRunningEntries, {
-...params,
- workflowId: params.workflowId,
-})
+ sharedHandleExecutionErrorConsole(
+{ addConsole, updateConsole, cancelRunningEntries },
+{ ...params, workflowId: params.workflowId }
+ )
  },
- [addConsole, cancelRunningEntries]
+ [addConsole, cancelRunningEntries, updateConsole]
  )
 
  const handleExecutionCancelledConsole = useCallback(
- (params: { workflowId?: string; executionId?: string; durationMs?: number }) => {
+ (params: {
+ workflowId?: string
+ executionId?: string
+ durationMs?: number
+ finalBlockLogs?: BlockLog[]
+ }) => {
  if (!params.workflowId) return
- sharedHandleExecutionCancelledConsole(addConsole, cancelRunningEntries, {
-...params,
- workflowId: params.workflowId,
-})
+ sharedHandleExecutionCancelledConsole(
+{ addConsole, updateConsole, cancelRunningEntries },
+{ ...params, workflowId: params.workflowId }
+ )
  },
- [addConsole, cancelRunningEntries]
+ [addConsole, cancelRunningEntries, updateConsole]
  )
 
  const buildBlockEventHandlers = useCallback(
@@ -1226,6 +1232,7 @@ export function useWorkflowExecution() {
  durationMs: data.duration,
  blockLogs: accumulatedBlockLogs,
  isPreExecutionError,
+ finalBlockLogs: data.finalBlockLogs,
  })
 
  if (activeWorkflowId && !isExecutingFromChat) {
@@ -1252,6 +1259,7 @@ export function useWorkflowExecution() {
  workflowId: activeWorkflowId,
  executionId: executionIdRef.current,
  durationMs: data?.duration,
+ finalBlockLogs: data?.finalBlockLogs,
  })
 
  if (activeWorkflowId && !isExecutingFromChat) {
@@ -1739,6 +1747,7 @@ export function useWorkflowExecution() {
  error: data.error,
  durationMs: data.duration,
  blockLogs: accumulatedBlockLogs,
+ finalBlockLogs: data.finalBlockLogs,
  })
 
  setCurrentExecutionId(workflowId, null)
@@ -1751,6 +1760,7 @@ export function useWorkflowExecution() {
  workflowId,
  executionId: executionIdRef.current,
  durationMs: data?.duration,
+ finalBlockLogs: data?.finalBlockLogs,
  })
 
  setCurrentExecutionId(workflowId, null)
@@ -1999,9 +2009,10 @@ export function useWorkflowExecution() {
  executionId: capturedExecutionId,
  error: data.error,
  blockLogs: accumulatedBlockLogs,
+ finalBlockLogs: data.finalBlockLogs,
  })
  },
- onExecutionCancelled: () => {
+ onExecutionCancelled: (data) => {
  reconnectionComplete = true
  activeReconnections.delete(reconnectWorkflowId)
  if (!activated) {
@@ -2018,6 +2029,8 @@ export function useWorkflowExecution() {
  handleExecutionCancelledConsole({
  workflowId: reconnectWorkflowId,
  executionId: capturedExecutionId,
+ durationMs: data?.duration,
+ finalBlockLogs: data?.finalBlockLogs,
  })
  },
  },