Skip to content

Commit 0d07ce2

Browse files
authored
feat: add waitUntil property to payload.jobs.queue (#9950)
1 parent a582431 commit 0d07ce2

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

packages/payload/src/queues/localAPI.ts

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
import type { RunningJobFromTask } from './config/types/workflowTypes.js'
1+
import type { BaseJob, RunningJobFromTask } from './config/types/workflowTypes.js'
22

33
import {
44
createLocalReq,
@@ -23,6 +23,7 @@ export const getJobsLocalAPI = (payload: Payload) => ({
2323
// TTaskOrWorkflowlug with keyof TypedJobs['workflows'] removed:
2424
task: TTaskOrWorkflowSlug extends keyof TypedJobs['tasks'] ? TTaskOrWorkflowSlug : never
2525
workflow?: never
26+
waitUntil?: Date
2627
}
2728
| {
2829
input: TypedJobs['workflows'][TTaskOrWorkflowSlug]['input']
@@ -32,6 +33,7 @@ export const getJobsLocalAPI = (payload: Payload) => ({
3233
workflow: TTaskOrWorkflowSlug extends keyof TypedJobs['workflows']
3334
? TTaskOrWorkflowSlug
3435
: never
36+
waitUntil?: Date
3537
},
3638
): Promise<
3739
TTaskOrWorkflowSlug extends keyof TypedJobs['workflows']
@@ -59,7 +61,8 @@ export const getJobsLocalAPI = (payload: Payload) => ({
5961
queue,
6062
taskSlug: 'task' in args ? args.task : undefined,
6163
workflowSlug: 'workflow' in args ? args.workflow : undefined,
62-
},
64+
waitUntil: args.waitUntil?.toISOString() ?? undefined,
65+
} as BaseJob,
6366
req: args.req,
6467
})) as TTaskOrWorkflowSlug extends keyof TypedJobs['workflows']
6568
? RunningJob<TTaskOrWorkflowSlug>

0 commit comments

Comments
 (0)