Function setWorkflowMcpTransactionLockTimeout

apps/sim/lib/mcp/server-locks.ts:8–12

(tx: DbOrTx)

const LOCK_NOT_AVAILABLE_SQLSTATE = '55P03'

export async function setWorkflowMcpTransactionLockTimeout(tx: DbOrTx): Promise<void> {
  await tx.execute(
    sql`select set_config('lock_timeout', ${`${MCP_SERVER_LOCK_TIMEOUT_MS}ms`}, true)`
  )
}

export async function acquireWorkflowMcpServerLock(tx: DbOrTx, serverId: string): Promise<void> {
  await setWorkflowMcpTransactionLockTimeout(tx)