fix(api): project pending resume attempts

Author: TheodoreSpeaks

apps/sim/lib/workflows/executor/execution-status.test.ts

@@ -57,7 +57,7 @@ describe('getWorkflowExecutionStatus queue projection', () => {
   })
 
   it('uses the resume entry ID when the queued work is a resume attempt', async () => {
-    queueTableRows(schemaMock.resumeQueue, [{ id: 'resume-entry-1' }])
+    queueTableRows(schemaMock.resumeQueue, [{ id: 'resume-entry-1', status: 'claimed' }])
     mockGetJob.mockResolvedValueOnce({
       status: 'processing',
       createdAt: new Date('2026-08-05T12:00:00.000Z'),
@@ -84,7 +84,7 @@ describe('getWorkflowExecutionStatus queue projection', () => {
         status: 'paused',
       },
     ])
-    queueTableRows(schemaMock.resumeQueue, [{ id: 'resume-entry-1' }])
+    queueTableRows(schemaMock.resumeQueue, [{ id: 'resume-entry-1', status: 'claimed' }])
     mockGetJob.mockResolvedValueOnce({
       status: 'pending',
       createdAt: new Date('2026-08-05T12:00:00.000Z'),
@@ -112,6 +112,7 @@ describe('getWorkflowExecutionStatus queue projection', () => {
     queueTableRows(schemaMock.resumeQueue, [
       {
         id: 'resume-entry-1',
+        status: 'claimed',
         queuedAt: new Date('2026-08-05T12:00:00.000Z'),
         claimedAt: new Date('2026-08-05T12:00:01.000Z'),
       },
@@ -129,6 +130,35 @@ describe('getWorkflowExecutionStatus queue projection', () => {
     })
   })
 
+  it('projects a pending serialized resume as queued', async () => {
+    queueTableRows(schemaMock.workflowExecutionLogs, [
+      {
+        executionId: 'execution-1',
+        workflowId: 'workflow-1',
+        status: 'paused',
+        trigger: 'api',
+      },
+    ])
+    queueTableRows(schemaMock.resumeQueue, [
+      {
+        id: 'resume-entry-2',
+        status: 'pending',
+        queuedAt: new Date('2026-08-05T12:00:02.000Z'),
+        claimedAt: null,
+      },
+    ])
+
+    const status = await getWorkflowExecutionStatus(input)
+
+    expect(status).toMatchObject({
+      executionId: 'execution-1',
+      status: 'queued',
+      startedAt: '2026-08-05T12:00:02.000Z',
+      paused: null,
+    })
+    expect(mockGetJob).not.toHaveBeenCalled()
+  })
+
   it('returns completed queue output when requested', async () => {
     mockGetJob.mockResolvedValueOnce({
       status: 'completed',

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

@@ -1,6 +1,6 @@
 import { db } from '@sim/db'
 import { pausedExecutions, resumeQueue, workflowExecutionLogs } from '@sim/db/schema'
-import { and, eq } from 'drizzle-orm'
+import { and, eq, inArray, sql } from 'drizzle-orm'
 import type { WorkflowExecutionStatusResponse } from '@/lib/api/contracts/workflows'
 import { getJobQueue } from '@/lib/core/async-jobs'
 import type { Job } from '@/lib/core/async-jobs/types'
@@ -157,6 +157,7 @@ export async function getWorkflowExecutionStatus(
   const [activeResume] = await db
     .select({
       id: resumeQueue.id,
+      status: resumeQueue.status,
       queuedAt: resumeQueue.queuedAt,
       claimedAt: resumeQueue.claimedAt,
     })
@@ -165,13 +166,16 @@ export async function getWorkflowExecutionStatus(
       and(
         eq(resumeQueue.parentExecutionId, executionId),
         eq(resumeQueue.newExecutionId, executionId),
-        eq(resumeQueue.status, 'claimed')
+        inArray(resumeQueue.status, ['pending', 'claimed'] as const)
       )
     )
+    .orderBy(sql`case when ${resumeQueue.status} = 'claimed' then 0 else 1 end`)
     .limit(1)
 
   const queueJobIds = [
-    ...(activeResume ? [`${RESUME_EXECUTION_JOB_ID_PREFIX}${activeResume.id}`] : []),
+    ...(activeResume?.status === 'claimed'
+      ? [`${RESUME_EXECUTION_JOB_ID_PREFIX}${activeResume.id}`]
+      : []),
     ...(!logRow ? [`${WORKFLOW_EXECUTION_JOB_ID_PREFIX}${executionId}`] : []),
   ]
 
@@ -184,13 +188,13 @@ export async function getWorkflowExecutionStatus(
     }
   }
 
-  if (activeResume && logRow) {
+  if (activeResume) {
     const startedAt = activeResume.claimedAt ?? activeResume.queuedAt
     return {
       executionId,
       workflowId,
       status: 'queued',
-      trigger: logRow.trigger,
+      trigger: logRow?.trigger ?? 'api',
       level: 'info',
       startedAt: startedAt.toISOString(),
       endedAt: null,