Race condition creating queues vs consuming from them

[LincolnPuzey]

Checklist

• Does your title concisely summarize the problem?
• Did you include a minimal, reproducible example?
• What OS are you using?
• What version of Python are you using?
• What version of Dramatiq are you using?
• What Broker are you using?
• What did you do?
• What did you expect would happen?
• What happened?

What OS are you using?

Debian trixie

What version of Python are you using?

3.13

What version of Dramatiq are you using?

1.18.0

What Broker are you using?

RabbitMQ

What did you do?

Start worker for the first time, when queues don't exist yet in rabbitMQ

What did you expect would happen?

No error logs

What happened?

Get some error logs, e.g.

[PID 1] [MainThread] [dramatiq.MainProcess] [INFO] Dramatiq '1.18.0' is booting up.
[PID 10] [MainThread] [dramatiq.WorkerProcess(0)] [INFO] Worker process is ready for action.
[PID 10] [Thread-12] [dramatiq.worker.ConsumerThread(default.DQ)] [CRITICAL] Consumer encountered a connection error: (404, "NOT_FOUND - no queue 'default.DQ' in vhost '[redacted]'")
[PID 10] [Thread-12] [dramatiq.worker.ConsumerThread(default.DQ)] [INFO] Restarting consumer in 3.00 seconds.