fix: mprocs failing cause source: not found

PostHog · Jan 3, 2025 · c84b850 · c84b850
1 parent 1b9aa47
commit c84b850
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 2 deletions.
diff --git a/bin/mprocs.yaml b/bin/mprocs.yaml
@@ -1,9 +1,9 @@
 procs:
     celery-worker:
-        shell: 'bin/check_kafka_clickhouse_up && source ./bin/celery-queues.env && python manage.py run_autoreload_celery --type=worker'
+        shell: 'bin/check_kafka_clickhouse_up && ./bin/start-celery worker'
 
     celery-beat:
-        shell: 'bin/check_kafka_clickhouse_up && source ./bin/celery-queues.env && python manage.py run_autoreload_celery --type=beat'
+        shell: 'bin/check_kafka_clickhouse_up && ./bin/start-celery beat'
 
     plugin-server:
         shell: 'bin/check_kafka_clickhouse_up && ./bin/plugin-server'

diff --git a/bin/start-celery b/bin/start-celery
@@ -0,0 +1,12 @@
+#!/bin/bash
+# Starts a celery worker / heartbeat job. Must be run with a type of process: worker | beat
+
+set -e
+
+# this kills all processes when the last one terminates
+trap 'kill $(jobs -p)' EXIT
+
+source ./bin/celery-queues.env
+
+# start celery worker with heartbeat (-B)
+python manage.py run_autoreload_celery --type=$1