File tree Expand file tree Collapse file tree 3 files changed +14
-4
lines changed
packages/scheduled-tasks/src/lib Expand file tree Collapse file tree 3 files changed +14
-4
lines changed Original file line number Diff line number Diff line change @@ -65,7 +65,8 @@ export class ScheduledTaskHandler {
65
65
every : options . interval !
66
66
}
67
67
: {
68
- pattern : options . pattern !
68
+ pattern : options . pattern ! ,
69
+ tz : options . timezone
69
70
}
70
71
} ;
71
72
}
@@ -87,6 +88,7 @@ export class ScheduledTaskHandler {
87
88
}
88
89
: {
89
90
pattern : piece . pattern ! ,
91
+ timezone : piece . timezone ,
90
92
customJobOptions : piece . customJobOptions
91
93
} )
92
94
}
Original file line number Diff line number Diff line change @@ -9,13 +9,15 @@ import type { JobsOptions } from 'bullmq';
9
9
export abstract class ScheduledTask < Options extends ScheduledTask . Options = ScheduledTask . Options > extends Piece < Options , 'scheduled-tasks' > {
10
10
public readonly interval : number | null ;
11
11
public readonly pattern : string | null ;
12
+ public readonly timezone : string ;
12
13
public readonly customJobOptions ?: ScheduledTaskCustomJobOptions ;
13
14
14
15
public constructor ( context : ScheduledTask . LoaderContext , options : ScheduledTaskOptions ) {
15
16
super ( context , options ) ;
16
17
this . interval = options . interval ?? null ;
17
18
this . pattern = options . pattern ?? null ;
18
19
this . customJobOptions = options . customJobOptions ;
20
+ this . timezone = options . timezone ?? 'UTC' ;
19
21
}
20
22
21
23
public abstract run ( payload : unknown ) : Awaitable < unknown > ;
@@ -37,6 +39,12 @@ export interface ScheduledTaskOptions extends Piece.Options {
37
39
* Custom options to pass to the job scheduler.
38
40
*/
39
41
customJobOptions ?: ScheduledTaskCustomJobOptions ;
42
+
43
+ /**
44
+ * The timezone to use for the task.
45
+ * @default 'UTC'
46
+ */
47
+ timezone ?: string | null ;
40
48
}
41
49
42
50
/**
Original file line number Diff line number Diff line change @@ -42,9 +42,9 @@ export type ScheduledTaskListRepeatedReturnType = ReturnType<BullClient['getRepe
42
42
export type ScheduledTasksTaskOptions = {
43
43
repeated : boolean ;
44
44
} & (
45
- | { delay : number ; interval ?: never ; pattern ?: never ; customJobOptions ?: ScheduledTaskCustomJobOptions }
46
- | { delay ?: never ; interval : number ; pattern ?: never ; customJobOptions ?: ScheduledTaskCustomJobOptions }
47
- | { delay ?: never ; interval ?: never ; pattern : string ; customJobOptions ?: ScheduledTaskCustomJobOptions }
45
+ | { delay : number ; interval ?: never ; pattern ?: never ; timezone ?: never ; customJobOptions ?: ScheduledTaskCustomJobOptions }
46
+ | { delay ?: never ; interval : number ; pattern ?: never ; timezone ?: never ; customJobOptions ?: ScheduledTaskCustomJobOptions }
47
+ | { delay ?: never ; interval ?: never ; pattern : string ; timezone : string ; customJobOptions ?: ScheduledTaskCustomJobOptions }
48
48
) ;
49
49
50
50
/**
You can’t perform that action at this time.
0 commit comments