diff --git a/apps/webapp/app/services/runs/startRun.server.ts b/apps/webapp/app/services/runs/startRun.server.ts index 62f9f0ed1..6d9f2ab03 100644 --- a/apps/webapp/app/services/runs/startRun.server.ts +++ b/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 } }, diff --git a/apps/webapp/app/services/sources/handleWebhookRequest.server.ts b/apps/webapp/app/services/sources/handleWebhookRequest.server.ts index d8265864e..c0c3ddf0e 100644 --- a/apps/webapp/app/services/sources/handleWebhookRequest.server.ts +++ b/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 } }, diff --git a/apps/webapp/app/v3/services/triggerTask.server.ts b/apps/webapp/app/v3/services/triggerTask.server.ts index ddacf1b1b..b906d2f4e 100644 --- a/apps/webapp/app/v3/services/triggerTask.server.ts +++ b/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: {