Skip to content

Commit 008de3b

Browse files
committed
finalize run service takes care of acks now
1 parent aee555a commit 008de3b

File tree

1 file changed

+0
-3
lines changed

1 file changed

+0
-3
lines changed

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

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
import { TaskRun, TaskRunAttempt } from "@trigger.dev/database";
22
import { eventRepository } from "../eventRepository.server";
3-
import { marqs } from "~/v3/marqs/index.server";
43
import { BaseService } from "./baseService.server";
54
import { logger } from "~/services/logger.server";
65
import { AuthenticatedEnvironment } from "~/services/apiAuth.server";
@@ -140,8 +139,6 @@ export class CrashTaskRunService extends BaseService {
140139
span.setAttribute("taskRunId", run.id);
141140
span.setAttribute("attemptId", attempt.id);
142141

143-
await marqs?.acknowledgeMessage(run.id);
144-
145142
await this._prisma.taskRunAttempt.update({
146143
where: {
147144
id: attempt.id,

0 commit comments

Comments
 (0)