Merge branch 'release/0.3.44' into main

bin/scripts/celery/live/start_celery.sh

@@ -1,5 +1,2 @@
 cd ~/app &&
-celery multi start w1 w2 -A meta_edc -l INFO --workdir="/home/live/app/" --logfile=/home/live/log/%n%I.log --pidfile=/home/live/celery/%n.pid
-
-# to stop
-# celery multi stop w1
+celery multi start worklive -A meta_edc.celery_live:app -Q live_queue -l INFO --workdir="/home/live/app/" --logfile=/home/live/log/%n%I.log --pidfile=/home/live/celery/%n.pid

bin/scripts/celery/uat/start_celery.sh

@@ -1,5 +1,2 @@
 cd ~/app &&
-celery multi start w1 w2 -A meta_edc -l INFO --workdir="/home/uat/app/" --logfile=/home/uat/log/%n%I.log --pidfile=/home/uat/celery/%n.pid
-
-# to stop
-# celery multi stop w1
+celery multi start workuat -A meta_edc.celery_uat:app -Q uat_queue -l INFO --workdir="/home/uat/app/" --logfile=/home/uat/log/%n%I.log --pidfile=/home/uat/celery/%n.pid

meta_edc/celery_live.py

@@ -0,0 +1,20 @@
+import os
+
+from celery import Celery
+
+# load settings
+os.environ.setdefault("DJANGO_SETTINGS_MODULE", "meta_edc.settings.debug")
+
+# config celery
+app = Celery("meta_edc")
+app.config_from_object("django.conf:settings", namespace="CELERY")
+app.autodiscover_tasks()
+
+app.conf.task_routes = {
+    "*": {"queue": "live_queue"},
+}
+
+
+@app.task(bind=True)
+def debug_task(self):
+    print("Request: {0!r}".format(self.request))

meta_edc/celery_uat.py

@@ -0,0 +1,20 @@
+import os
+
+from celery import Celery
+
+# load settings
+os.environ.setdefault("DJANGO_SETTINGS_MODULE", "meta_edc.settings.debug")
+
+# config celery
+app = Celery("meta_edc")
+app.config_from_object("django.conf:settings", namespace="CELERY")
+app.autodiscover_tasks()
+
+app.conf.task_routes = {
+    "*": {"queue": "uat_queue"},
+}
+
+
+@app.task(bind=True)
+def debug_task(self):
+    print("Request: {0!r}".format(self.request))