Merge pull request #18 from edx/nadeem/fix-ecomworker

fix: replace queue with queues parameter in celery process
edx · May 24, 2024 · dbb9b04 · dbb9b04
2 parents 42db043 + b71f328
commit dbb9b04
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/playbooks/roles/ecomworker/templates/edx/app/ecomworker/ecomworker.sh.j2 b/playbooks/roles/ecomworker/templates/edx/app/ecomworker/ecomworker.sh.j2
@@ -26,4 +26,4 @@ export DD_TRACE_LOG_STREAM_HANDLER=false
 
 source {{ ecommerce_worker_home }}/{{ ecommerce_worker_service_name }}_env
 # We exec so that celery is the child of supervisor and can be managed properly
-exec {{ executable }} -A ecommerce_worker.celery_app:app worker --concurrency={{ ECOMMERCE_WORKER_CONCURRENCY }} --loglevel=info --hostname=ecomworker.%%h --queue=ecommerce.fulfillment,ecommerce.email_marketing,ecommerce.default
+exec {{ executable }} -A ecommerce_worker.celery_app:app worker --concurrency={{ ECOMMERCE_WORKER_CONCURRENCY }} --loglevel=info --hostname=ecomworker.%%h --queues=ecommerce.fulfillment,ecommerce.email_marketing,ecommerce.default