Solution for celery problems

mrbotcr · Jul 29, 2021 · 1a000e1 · 1a000e1
1 parent 34798e2
commit 1a000e1
Show file tree

Hide file tree

Showing 13 changed files with 6,190 additions and 8,298 deletions.
diff --git a/climmob/config/celery_class.py b/climmob/config/celery_class.py
@@ -2,8 +2,9 @@
 from sqlalchemy import create_engine
 from climmob.config.celery_app import get_ini_value
 
+from celery.contrib.abortable import AbortableTask
 
-class celeryTask(Task):
+class celeryTask(AbortableTask):
     def on_success(self, retval, task_id, args, kwargs):
         engine = create_engine(get_ini_value("sqlalchemy.url"))
         engine.execute(

diff --git a/climmob/config/celery_config.py b/climmob/config/celery_config.py
@@ -1 +1 @@
-BROKER_POOL_LIMIT = None
+#broker_pool_limit = None
Original file line number	Diff line number	Diff line change
		@@ -1 +1 @@
		BROKER_POOL_LIMIT = None
		#broker_pool_limit = None