Function markExecutionCancelled

apps/sim/lib/execution/cancellation.ts:43–62

(
  executionId: string
)

/** Writes the durable key first, then publishes — so a late subscriber still sees the flag on backstop check. */
export async function markExecutionCancelled(
  executionId: string
): Promise<ExecutionCancellationRecordResult> {
  const redis = getRedisClient()
  if (!redis) {
    getCancellationChannel().publish({ executionId })
    return { durablyRecorded: false, reason: 'redis_unavailable' }
  }

  try {
    await redis.set(`${EXECUTION_CANCEL_PREFIX}${executionId}`, '1', 'EX', EXECUTION_CANCEL_EXPIRY)
    logger.info('Marked execution as cancelled', { executionId })
    getCancellationChannel().publish({ executionId })
    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' }
  }
}

export async function isExecutionCancelled(executionId: string): Promise<boolean> {
  const redis = getRedisClient()