Function getCancellationChannel

apps/sim/lib/execution/cancellation.ts:28–36

()

const _g = globalThis as CancellationGlobal

export function getCancellationChannel(): PubSubChannel<ExecutionCancelEvent> {
  if (!_g._executionCancelChannel) {
    _g._executionCancelChannel = createPubSubChannel<ExecutionCancelEvent>({
      channel: EXECUTION_CANCEL_CHANNEL,
      label: 'execution-cancel',
    })
  }
  return _g._executionCancelChannel
}

export function isRedisCancellationEnabled(): boolean {
  return getRedisClient() !== null