Function releasePendingChatStream

apps/sim/lib/copilot/request/session/abort.ts:175–187

(chatId: string, streamId: string)

}

export async function releasePendingChatStream(chatId: string, streamId: string): Promise<void> {
  try {
    await releaseLock(getChatStreamLockKey(chatId), streamId)
  } catch (error) {
    logger.warn('Failed to release chat stream lock', {
      chatId,
      streamId,
      error: toError(error).message,
    })
  } finally {
    resolvePendingChatStream(chatId, streamId)
  }
}

export async function acquirePendingChatStream(
  chatId: string,