Skip to content

Commit e1d1189

Browse files
committed
fix: add misfire grace time and max instances to scheduled jobs
1 parent d00cdd7 commit e1d1189

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

apps/trigger/handler/impl/trigger/scheduled_trigger.py

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -53,6 +53,8 @@ def _deploy_daily(trigger: dict, trigger_tasks: list[dict], setting: dict, trigg
5353
id=job_id,
5454
kwargs={"trigger": trigger, "trigger_task": task},
5555
replace_existing=True,
56+
misfire_grace_time=60,
57+
max_instances=1,
5658
)
5759

5860

@@ -90,6 +92,8 @@ def _deploy_weekly(trigger: dict, trigger_tasks: list[dict], setting: dict, trig
9092
id=job_id,
9193
kwargs={"trigger": trigger, "trigger_task": task},
9294
replace_existing=True,
95+
misfire_grace_time=60,
96+
max_instances=1,
9397
)
9498

9599

@@ -129,6 +133,8 @@ def _deploy_monthly(trigger: dict, trigger_tasks: list[dict], setting: dict, tri
129133
id=job_id,
130134
kwargs={"trigger": trigger, "trigger_task": task},
131135
replace_existing=True,
136+
misfire_grace_time=60,
137+
max_instances=1,
132138
)
133139

134140
def _deploy_cron(trigger: dict, trigger_tasks: list[dict], setting: dict, trigger_id: str) -> None:
@@ -154,6 +160,8 @@ def _deploy_cron(trigger: dict, trigger_tasks: list[dict], setting: dict, trigge
154160
id=job_id,
155161
kwargs={"trigger": trigger, "trigger_task": task},
156162
replace_existing=True,
163+
misfire_grace_time=60,
164+
max_instances=1,
157165
)
158166

159167
def _deploy_interval(trigger: dict, trigger_tasks: list[dict], setting: dict, trigger_id: str) -> None:
@@ -182,6 +190,8 @@ def _deploy_interval(trigger: dict, trigger_tasks: list[dict], setting: dict, tr
182190
id=job_id,
183191
kwargs={"trigger": trigger, "trigger_task": task},
184192
replace_existing=True,
193+
misfire_grace_time=60,
194+
max_instances=1,
185195
**{unit: value_i},
186196
)
187197

0 commit comments

Comments
 (0)