parallelvirtualcluster
/
pvc
1
0
Fork 0
Code Issues 11 Pull Requests Projects Releases 111 Wiki Activity

Enable extended Celery results

This commit is contained in:
Joshua Boniface 2023-11-16 12:02:57 -05:00
parent fa361a55d9
commit d226e9f4e5
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
api-daemon/pvcapid/flaskapi.py
View File

@ -56,12 +56,11 @@ from flask_sqlalchemy import SQLAlchemy
# Create Flask app and set config values # Create Flask app and set config values
app = flask.Flask(__name__) app = flask.Flask(__name__)
app.config["CELERY_BROKER_URL"] = "redis://{}:{}{}".format( celery_task_uri = "redis://{}:{}{}".format(
config["queue_host"], config["queue_port"], config["queue_path"]
)
app.config["CELERY_RESULT_BACKEND"] = "redis://{}:{}{}".format(
config["queue_host"], config["queue_port"], config["queue_path"] config["queue_host"], config["queue_port"], config["queue_path"]
) )
app.config["CELERY_BROKER_URL"] = celery_task_uri
app.config["CELERY_RESULT_BACKEND"] = celery_task_uri
# Set up Celery queues # Set up Celery queues
@ -132,7 +131,12 @@ api = Api(blueprint)
app.register_blueprint(blueprint) app.register_blueprint(blueprint)
# Create celery definition # Create celery definition
celery = Celery(app.name, broker=app.config["CELERY_BROKER_URL"]) celery = Celery(
app.name,
broker=celery_task_uri,
result_backend=celery_task_uri,
result_extended=True,
)
celery.conf.update(app.config) celery.conf.update(app.config)
# #