Skip to content

Commit 793bbc3

Browse files
committed
chore: add Celery task decorator to _remove_trigger_jobs and update job invocation
--bug=1065881@tapd-62980211 --user=刘瑞斌 【触发器】触发器关联一个应用,每隔1分钟执行一次,执行时会同时执行多次任务 https://www.tapd.cn/62980211/s/1837079
1 parent 15e4f04 commit 793bbc3

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -163,7 +163,7 @@ def _deploy_interval(trigger: dict, trigger_tasks: list[dict], setting: dict, tr
163163
**{unit: value_i},
164164
)
165165

166-
166+
@celery_app.task(name="celery:undeploy_scheduled_trigger")
167167
def _remove_trigger_jobs(trigger_id: str) -> None:
168168
from common.job import scheduler
169169

@@ -256,6 +256,6 @@ def undeploy(self, trigger, **kwargs):
256256
return
257257

258258
try:
259-
_remove_trigger_jobs(trigger_id)
259+
_remove_trigger_jobs.delay(trigger_id)
260260
finally:
261261
rlock.un_lock(lock_key)

0 commit comments

Comments
 (0)