|
2 | 2 |
|
3 | 3 | from django.db.models import QuerySet |
4 | 4 |
|
5 | | -from common.utils.lock import RedisLock |
6 | 5 | from common.utils.logger import maxkb_logger |
7 | 6 | from ops import celery_app |
8 | 7 | from trigger.handler.base_trigger import BaseTrigger |
@@ -236,26 +235,9 @@ def deploy(self, trigger, **kwargs): |
236 | 235 | self.undeploy(trigger, **kwargs) |
237 | 236 | return |
238 | 237 |
|
239 | | - rlock = RedisLock() |
240 | | - lock_key = f"scheduled_trigger_deploy:{trigger_id}" |
241 | | - if not rlock.try_lock(lock_key, 30): |
242 | | - return |
243 | | - |
244 | | - try: |
245 | | - maxkb_logger.debug(f"get lock {lock_key}") |
246 | | - deploy_scheduled_trigger.delay(trigger, trigger_tasks, setting, schedule_type) |
247 | | - finally: |
248 | | - rlock.un_lock(lock_key) |
| 238 | + deploy_scheduled_trigger.delay(trigger, trigger_tasks, setting, schedule_type) |
249 | 239 |
|
250 | 240 | def undeploy(self, trigger, **kwargs): |
251 | 241 | trigger_id = str(trigger["id"]) |
252 | 242 |
|
253 | | - rlock = RedisLock() |
254 | | - lock_key = f"scheduled_trigger_deploy:{trigger_id}" |
255 | | - if not rlock.try_lock(lock_key, 30): |
256 | | - return |
257 | | - |
258 | | - try: |
259 | | - _remove_trigger_jobs.delay(trigger_id) |
260 | | - finally: |
261 | | - rlock.un_lock(lock_key) |
| 243 | + _remove_trigger_jobs.delay(trigger_id) |
0 commit comments