Function lockWorkflowForUpdate

apps/sim/lib/workflows/persistence/utils.ts:42–57

(tx: DbOrTx, workflowId: string)

}

async function lockWorkflowForUpdate(tx: DbOrTx, workflowId: string): Promise<boolean> {
  const query = tx.select({ id: workflow.id }).from(workflow).where(eq(workflow.id, workflowId))

  if ('limit' in query && typeof query.limit === 'function') {
    const limited = query.limit(1)
    const rows =
      'for' in limited && typeof limited.for === 'function'
        ? await limited.for('update')
        : await limited
    return hasReturnedRows(rows)
  }

  const rows = await query

  return hasReturnedRows(rows)
}

export interface WorkflowDeploymentVersionResponse {
  id: string