add missing ack on checkpoint creation service failure

This commit is contained in:
nicktrn
2024-05-03 14:29:07 +01:00
parent 30b6c2c35e
commit 4ace3a4bb7
@@ -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";
}