diff --git a/apps/webapp/app/v3/services/completeAttempt.server.ts b/apps/webapp/app/v3/services/completeAttempt.server.ts index ec4bc6e35..b2d5dfe94 100644 --- a/apps/webapp/app/v3/services/completeAttempt.server.ts +++ b/apps/webapp/app/v3/services/completeAttempt.server.ts @@ -56,6 +56,8 @@ export class CompleteAttemptService extends BaseService { }, }); + // No attempt, so there's no message to ACK + return "COMPLETED"; } @@ -142,6 +144,8 @@ export class CompleteAttemptService extends BaseService { env ); + // The cancel service handles ACK + return "COMPLETED"; } @@ -226,6 +230,8 @@ export class CompleteAttemptService extends BaseService { }, }); + await marqs?.acknowledgeMessage(taskRunAttempt.taskRunId); + return "COMPLETED"; }