fix(executor): publish cancellation event on Redis write failure

Author: waleedlatif1

apps/sim/lib/execution/cancellation.test.ts

@@ -59,6 +59,15 @@ describe('markExecutionCancelled', () => {
     })
   })
 
+  it('publishes even when the Redis write fails so local subscribers wake up', async () => {
+    mockRedisSet.mockRejectedValue(new Error('set failed'))
+    mockGetRedisClient.mockReturnValue({ set: mockRedisSet })
+
+    await markExecutionCancelled('execution-write-failed')
+
+    expect(mockPublish).toHaveBeenCalledWith({ executionId: 'execution-write-failed' })
+  })
+
   it('publishes a cancellation event after a successful Redis write', async () => {
     mockRedisSet.mockResolvedValue('OK')
     mockGetRedisClient.mockReturnValue({ set: mockRedisSet })

apps/sim/lib/execution/cancellation.ts

@@ -52,6 +52,7 @@ export async function markExecutionCancelled(
     return { durablyRecorded: true, reason: 'recorded' }
   } catch (error) {
     logger.error('Failed to mark execution as cancelled', { executionId, error })
+    getCancellationChannel().publish({ executionId })
     return { durablyRecorded: false, reason: 'redis_write_failed' }
   }
 }