Revert "disable advisory locks"

This reverts commit 892fd9f.

Author: ericallam

apps/webapp/app/services/runs/startRun.server.ts

@@ -64,6 +64,8 @@ export class StartRunService {
     await $transaction(
       this.#prismaClient,
       async (tx) => {
+        await tx.$executeRaw`SELECT pg_advisory_xact_lock(${lockId})`;
+
         const counter = await tx.jobCounter.upsert({
           where: { jobId: run.jobId },
           update: { lastNumber: { increment: 1 } },

apps/webapp/app/services/sources/handleWebhookRequest.server.ts

@@ -37,6 +37,8 @@ export class HandleWebhookRequestService {
     const lockId = webhookIdToLockId(webhookEnvironment.webhookId);
 
     await this.#prismaClient.$transaction(async (tx) => {
+      await tx.$executeRaw`SELECT pg_advisory_xact_lock(${lockId})`;
+
       const counter = await tx.webhookDeliveryCounter.upsert({
         where: { webhookId: webhookEnvironment.id },
         update: { lastNumber: { increment: 1 } },

apps/webapp/app/v3/services/triggerTask.server.ts

@@ -88,6 +88,8 @@ export class TriggerTaskService extends BaseService {
           const lockId = taskIdentifierToLockId(taskId);
 
           const run = await $transaction(this._prisma, async (tx) => {
+            await tx.$executeRaw`SELECT pg_advisory_xact_lock(${lockId})`;
+
             const lockedToBackgroundWorker = body.options?.lockToVersion
               ? await tx.backgroundWorker.findUnique({
                   where: {