File tree Expand file tree Collapse file tree 1 file changed +10
-8
lines changed Expand file tree Collapse file tree 1 file changed +10
-8
lines changed Original file line number Diff line number Diff line change @@ -67,7 +67,11 @@ export type ZodTasks<TConsumerSchema extends MessageCatalogSchema> = {
67
67
maxAttempts ?: number ;
68
68
jobKeyMode ?: "replace" | "preserve_run_at" | "unsafe_dedupe" ;
69
69
flags ?: string [ ] ;
70
- handler : ( payload : z . infer < TConsumerSchema [ K ] > , job : GraphileJob , helpers : JobHelpers ) => Promise < void > ;
70
+ handler : (
71
+ payload : z . infer < TConsumerSchema [ K ] > ,
72
+ job : GraphileJob ,
73
+ helpers : JobHelpers
74
+ ) => Promise < void > ;
71
75
} ;
72
76
} ;
73
77
@@ -80,7 +84,11 @@ export type ZodRecurringTasks = {
80
84
[ key : string ] : {
81
85
match : string ;
82
86
options ?: CronItemOptions ;
83
- handler : ( payload : RecurringTaskPayload , job : GraphileJob , helpers : JobHelpers ) => Promise < void > ;
87
+ handler : (
88
+ payload : RecurringTaskPayload ,
89
+ job : GraphileJob ,
90
+ helpers : JobHelpers
91
+ ) => Promise < void > ;
84
92
} ;
85
93
} ;
86
94
@@ -330,12 +338,6 @@ export class ZodWorker<TMessageCatalog extends MessageCatalogSchema> {
330
338
}
331
339
}
332
340
333
- logger . debug ( "Enqueuing worker task" , {
334
- identifier,
335
- payload,
336
- spec,
337
- } ) ;
338
-
339
341
const { job, durationInMs } = await this . #addJob(
340
342
identifier as string ,
341
343
payload ,
You can’t perform that action at this time.
0 commit comments