Add threading configuration for dramatiq worker (#56)

safe-global · Jan 8, 2025 · c5cc1c0 · c5cc1c0
1 parent 73e13c4
commit c5cc1c0
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/docker/web/dramatiq/worker/run.sh b/docker/web/dramatiq/worker/run.sh
@@ -2,7 +2,10 @@
 
 set -euo pipefail
 
-dramatiq app.workers.tasks & # dramatiq async actors
+TASK_CONCURRENCY=${TASK_CONCURRENCY:-100}
+
+echo "==> $(date +%H:%M:%S) ==> Running Dramatiq worker with concurrency $TASK_CONCURRENCY <=="
+dramatiq app.workers.tasks --processes 1 --threads $TASK_CONCURRENCY & # dramatiq async actors
 periodiq -v app.workers.tasks & # cron dramatiq async actors
 
 wait