Skip to content

Commit 7553d8c

Browse files
committed
Remove unneeded tx
1 parent 4bb7220 commit 7553d8c

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,7 @@ export class CancelTaskAttemptDependenciesService extends BaseService {
5757
}
5858
}
5959

60-
static async enqueue(attemptId: string, tx: PrismaClientOrTransaction, runAt?: Date) {
60+
static async enqueue(attemptId: string, runAt?: Date) {
6161
return await commonWorker.enqueue({
6262
id: `cancelTaskAttemptDependencies:${attemptId}`,
6363
job: "v3.cancelTaskAttemptDependencies",

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,7 @@ export class CancelTaskRunServiceV1 extends BaseService {
116116
attempts: ExtendedTaskRunAttempt[]
117117
) {
118118
for (const attempt of attempts) {
119-
await CancelTaskAttemptDependenciesService.enqueue(attempt.id, this._prisma);
119+
await CancelTaskAttemptDependenciesService.enqueue(attempt.id);
120120

121121
if (run.runtimeEnvironment.type === "DEVELOPMENT") {
122122
// Signal the task run attempt to stop

0 commit comments

Comments
 (0)