diff --git a/api-daemon/pvcapid/flaskapi.py b/api-daemon/pvcapid/flaskapi.py index f11ec2a7..691df059 100755 --- a/api-daemon/pvcapid/flaskapi.py +++ b/api-daemon/pvcapid/flaskapi.py @@ -118,7 +118,7 @@ celery_task_uri = "redis://{}:{}{}".format( celery = Celery( app.name, broker=celery_task_uri, - result_backend=celery_task_uri, + backend=celery_task_uri, result_extended=True, ) app.config["broker_url"] = celery_task_uri diff --git a/worker-daemon/pvcworkerd/Daemon.py b/worker-daemon/pvcworkerd/Daemon.py index bb7cb9ad..d06c9be3 100755 --- a/worker-daemon/pvcworkerd/Daemon.py +++ b/worker-daemon/pvcworkerd/Daemon.py @@ -58,7 +58,7 @@ celery_task_uri = "redis://{}:{}{}".format( celery = Celery( "pvcworkerd", broker=celery_task_uri, - result_backend=celery_task_uri, + backend=celery_task_uri, result_extended=True, )