One queue for each test suite

getsentry · Jun 11, 2024 · a1fb71a · a1fb71a
1 parent 3e85ea5
commit a1fb71a
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/tests/integrations/celery/integration_tests/test_celery_beat_cron_monitoring.py b/tests/integrations/celery/integration_tests/test_celery_beat_cron_monitoring.py
@@ -1,3 +1,4 @@
+import os
 import pytest
 
 from celery.contrib.testing.worker import start_worker
@@ -15,6 +16,8 @@ def celery_config():
         "task_always_eager": False,
         "worker_concurrency": 1,
         "beat_scheduler": "tests.integrations.celery.integration_tests:ImmediateScheduler",
+        "task_create_missing_queues": True,
+        "task_routes": {'*': {'queue': f'queue_{os.getpid()}'}},
     }