From e9faf20909bf49bd59b6c1426a987d5cbdb5bdea Mon Sep 17 00:00:00 2001 From: Raymond Jacobson Date: Tue, 12 Sep 2023 10:19:42 -0600 Subject: [PATCH] [PROTO-1250] Move celery to eventlets --- discovery-provider/scripts/start.sh | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/discovery-provider/scripts/start.sh b/discovery-provider/scripts/start.sh index 211c30e05dd..21f35e9af4f 100755 --- a/discovery-provider/scripts/start.sh +++ b/discovery-provider/scripts/start.sh @@ -52,7 +52,7 @@ if [[ "$audius_discprov_dev_mode" == "true" ]]; then [ -e /var/celerybeat-schedule ] && rm /var/celerybeat-schedule [ -e /var/celerybeat.pid ] && rm /var/celerybeat.pid audius_service=beat celery -A src.worker.celery beat --schedule=/var/celerybeat-schedule --pidfile=/var/celerybeat.pid --loglevel WARNING 2>&1 | tee >(logger -t beat) & - audius_service=worker watchmedo auto-restart --directory ./ --pattern=*.py --recursive -- celery -A src.worker.celery worker --loglevel $audius_discprov_loglevel 2>&1 | tee >(logger -t worker) & + audius_service=worker watchmedo auto-restart --directory ./ --pattern=*.py --recursive -- celery -A src.worker.celery worker --pool eventlet --concurrency 50 --loglevel $audius_discprov_loglevel 2>&1 | tee >(logger -t worker) & fi else if [[ "$audius_no_server" != "true" ]] && [[ "$audius_no_server" != "1" ]]; then @@ -64,7 +64,7 @@ else [ -e /var/celerybeat-schedule ] && rm /var/celerybeat-schedule [ -e /var/celerybeat.pid ] && rm /var/celerybeat.pid audius_service=beat celery -A src.worker.celery beat --schedule=/var/celerybeat-schedule --pidfile=/var/celerybeat.pid --loglevel WARNING 2>&1 | tee >(logger -t beat) & - audius_service=worker celery -A src.worker.celery worker --max-memory-per-child 300000 --loglevel $audius_discprov_loglevel 2>&1 | tee >(logger -t worker) & + audius_service=worker celery -A src.worker.celery worker --pool eventlet --concurrency 50 --loglevel $audius_discprov_loglevel 2>&1 | tee >(logger -t worker) & fi fi