From ab629f6b51e6a0411a3f774da6eac2710d5cd776 Mon Sep 17 00:00:00 2001 From: "Joshua M. Boniface" Date: Sat, 4 Nov 2023 13:02:30 -0400 Subject: [PATCH] Use per-host hostname and queues in worker Opens up the ability to direct tasks to specific workers. --- api-daemon/pvcapid-worker.sh | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/api-daemon/pvcapid-worker.sh b/api-daemon/pvcapid-worker.sh index eda3b383..4ad6b89c 100755 --- a/api-daemon/pvcapid-worker.sh +++ b/api-daemon/pvcapid-worker.sh @@ -25,10 +25,10 @@ CELERY_BIN="$( which celery )" # app arguments work in a non-backwards-compatible way with Celery 5. case "$( cat /etc/debian_version )" in 10.*) - CELERY_ARGS="worker --app pvcapid.flaskapi.celery --concurrency 1 --loglevel INFO" + CELERY_ARGS="worker --app pvcapid.flaskapi.celery --concurrency 1 --hostname $(hostname -s) --queues $(hostname -s) --loglevel INFO" ;; *) - CELERY_ARGS="--app pvcapid.flaskapi.celery worker --concurrency 1 --loglevel INFO" + CELERY_ARGS="--app pvcapid.flaskapi.celery worker --concurrency 1 --hostname $(hostname -s) --queues $(hostname -s) --loglevel INFO" ;; esac