Added integra task simultaneous execution prevention lock

core/utils/redis.py

@@ -0,0 +1,19 @@
+from functools import wraps
+
+from django.core.cache import cache
+
+
+def skip_locked(lock_name):
+    lock = cache.lock(lock_name)
+
+    def decorator(method):
+        @wraps(method)
+        def wrapper(*args, **kwargs):
+            if not lock.acquire(blocking=False):
+                return None
+            try:
+                return method(*args, **kwargs)
+            finally:
+                lock.release()
+        return wrapper
+    return decorator

lib/integra/tasks.py

@@ -2,6 +2,7 @@
 from celery.utils.log import get_task_logger
 from django.conf import settings
 
+from core.utils.redis import skip_locked
 from .utils import Loader, Updater
 
 LOGGER = get_task_logger(__name__)
@@ -40,6 +41,7 @@ def run(self):
 
 
 @shared_task
+@skip_locked('integra_task')
 def download_updates():
     processed, updated, errors = 0, 0, 0
     configs = getattr(settings, 'INTEGRA_CONFIGS', None)