disable advisory locks

Author: nicktrn

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

@@ -64,8 +64,6 @@ 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,8 +37,6 @@ 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,8 +88,6 @@ 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: {