Stress that worker uses Queue.slug instead of Queue.name

Author: dolfinus

docker-compose.test.yml

@@ -104,7 +104,7 @@ services:
       dockerfile: docker/Dockerfile.worker
       context: .
       target: test
-    command: --loglevel=info -Q test_queue
+    command: --loglevel=info -Q 123-test_queue
     entrypoint: [coverage, run, -m, celery, -A, tests.test_integration.celery_test, worker, --max-tasks-per-child=1]
     env_file:
       - .env.docker

docker-compose.yml

@@ -83,7 +83,7 @@ services:
       context: .
       target: prod
     env_file: .env.docker
-    command: --loglevel=info -Q test_queue
+    command: --loglevel=info -Q 123-test_queue  # Queue.slug
     depends_on:
       db:
         condition: service_healthy

docs/reference/worker/index.rst

@@ -12,7 +12,7 @@ executes them and updates status & log url in :ref:`database`. Implemented using
     This can be done via :ref:`frontend` or via :ref:`server` REST API.
 
     Queue field ``slug`` value is then should be passed to Celery argument ``-Q``.
-    For example, for slug ``test_queue`` this should be ``-Q test_queue``.
+    For example, for slug ``123-test_queue`` this should be ``-Q 123-test_queue``.
 
 Install & run
 -------------
@@ -70,18 +70,20 @@ Without docker
 
       $ pip install syncmaster[server,worker]
 
-* Start :ref:`server` and :ref:`frontend`, create Group and Queue, get slug (e.g. ``test_queue``)
+* Start :ref:`server` and :ref:`frontend`
+* Create new Group
+* Create Queue in this group, and then get **Queue.slug** (e.g. ``123-test_queue``)
 * Run worker process:
 
   .. code-block:: console
 
-    $ python -m celery -A syncmaster.worker.celery worker -Q test_queue --max-tasks-per-child=1
+    $ python -m celery -A syncmaster.worker.celery worker -Q 123-test_queue --max-tasks-per-child=1
 
   You can specify options like concurrency and queues by adding additional flags:
 
   .. code-block:: bash
 
-    $ python -m celery -A syncmaster.worker.celery worker -Q test_queue --max-tasks-per-child=1 --concurrency=4 --loglevel=info
+    $ python -m celery -A syncmaster.worker.celery worker -Q 123-test_queue --max-tasks-per-child=1 --concurrency=4 --loglevel=info
 
   Refer to the `Celery <https://docs.celeryq.dev/en/stable/>`_ documentation for more advanced start options.
 

tests/test_integration/test_run_transfer/connection_fixtures/connection_fixtures.py

@@ -44,7 +44,7 @@ async def group(
     await session.commit()
 
 
-@pytest_asyncio.fixture(params=["test_queue"])
+@pytest_asyncio.fixture(params=["123-test_queue"])
 async def queue(
     request: FixtureRequest,
     session: AsyncSession,

tests/test_integration/test_scheduler/scheduler_fixtures/transfer_fixture.py

@@ -45,9 +45,9 @@ async def group_transfer_integration_mock(
 
     queue = await create_queue(
         session=session,
-        name="test_queue",
+        name="123-test_queue",
         group_id=group.id,
-        slug="test_queue",
+        slug="123-test_queue",
     )
 
     members: list[MockUser] = []