Function acquireWorkflowMcpServerLock

apps/sim/lib/mcp/server-locks.ts:14–17

(tx: DbOrTx, serverId: string)

}

export async function acquireWorkflowMcpServerLock(tx: DbOrTx, serverId: string): Promise<void> {
  await setWorkflowMcpTransactionLockTimeout(tx)
  await tx.execute(sql`select pg_advisory_xact_lock(hashtextextended(${serverId}, 0))`)
}

export function isWorkflowMcpServerLockTimeout(error: unknown): boolean {
  return getPostgresErrorCode(error) === LOCK_NOT_AVAILABLE_SQLSTATE