-
Notifications
You must be signed in to change notification settings - Fork 31
Open
Description
Is your feature request related to a problem? Please describe.
Set a default --queues celery,low for the worker and worker-beat container commands to work with the new jobs scheduler. It probably makes sense to expose a parameter to configure these as well.
See also #218.
Describe the solution you'd like
--queues celery,lowadded to the worker-beat-deployment and worker-deployment templates- Related worker.queues and workerBeat.queues values to specify custom queues
Describe alternatives you've considered
I don't think you can specify celery queues with an environment variable (e.g. CELERY_QUEUES), otherwise this feature would essentially already be present with the worker.extraEnvVars parameter.
Additional context
This may be an InvenioRDM v13 feature, where invenio-jobs introduced the scheduler but also specified a new "low" priority queue. Without it, jobs sent to the "low" queue never complete. When I run v13 locally, the celery commands look like this:
celery --app invenio_app.celery worker --beat --events --loglevel INFO --queues celery,lowbut the commands of this chart's running containers lack the final --queues flag:
# worker
celery -A invenio_app.celery worker -c 2 -l INFO
# beat
celery -A invenio_app.celery beat -l INFO -s /var/run/celery/celery-schedule --pidfile /var/run/celery/celerybeat.pidJ4bbi
Metadata
Metadata
Assignees
Labels
No labels