diff --git a/apps/webapp/app/v3/services/resumeAttempt.server.ts b/apps/webapp/app/v3/services/resumeAttempt.server.ts index 03f4d362e..2e8b62735 100644 --- a/apps/webapp/app/v3/services/resumeAttempt.server.ts +++ b/apps/webapp/app/v3/services/resumeAttempt.server.ts @@ -96,6 +96,8 @@ export class ResumeAttemptService extends BaseService { attemptFriendlyId: params.attemptFriendlyId, }); + await this.#setPostResumeStatuses(attempt, tx); + socketIo.coordinatorNamespace.emit("RESUME_AFTER_DURATION", { version: "v1", attemptId: attempt.id, @@ -218,7 +220,20 @@ export class ResumeAttemptService extends BaseService { executions.push(executionPayload.execution); } - const updated = await tx.taskRunAttempt.update({ + await this.#setPostResumeStatuses(attempt, tx); + + socketIo.coordinatorNamespace.emit("RESUME_AFTER_DEPENDENCY", { + version: "v1", + runId: attempt.taskRunId, + attemptId: attempt.id, + attemptFriendlyId: attempt.friendlyId, + completions, + executions, + }); + } + + async #setPostResumeStatuses(attempt: TaskRunAttempt, tx: PrismaClientOrTransaction) { + return await tx.taskRunAttempt.update({ where: { id: attempt.id, }, @@ -233,14 +248,5 @@ export class ResumeAttemptService extends BaseService { }, }, }); - - socketIo.coordinatorNamespace.emit("RESUME_AFTER_DEPENDENCY", { - version: "v1", - runId: attempt.taskRunId, - attemptId: attempt.id, - attemptFriendlyId: attempt.friendlyId, - completions, - executions, - }); } }