File tree Expand file tree Collapse file tree 1 file changed +3
-1
lines changed
apps/webapp/app/v3/services Expand file tree Collapse file tree 1 file changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -12,6 +12,7 @@ import { socketIo } from "../handleSocketIo.server";
12
12
import { SharedQueueMessageBody , sharedQueueTasks } from "../marqs/sharedQueueConsumer.server" ;
13
13
import { BaseService } from "./baseService.server" ;
14
14
import { TaskRunAttempt } from "@trigger.dev/database" ;
15
+ import { isFinalRunStatus } from "../taskStatus" ;
15
16
16
17
export class ResumeAttemptService extends BaseService {
17
18
public async call (
@@ -80,10 +81,11 @@ export class ResumeAttemptService extends BaseService {
80
81
return ;
81
82
}
82
83
83
- if ( attempt . taskRun . status !== "WAITING_TO_RESUME" ) {
84
+ if ( isFinalRunStatus ( attempt . taskRun . status ) ) {
84
85
logger . error ( "Run is not resumable" , {
85
86
attemptId : attempt . id ,
86
87
runId : attempt . taskRunId ,
88
+ status : attempt . taskRun . status ,
87
89
} ) ;
88
90
return ;
89
91
}
You can’t perform that action at this time.
0 commit comments