Métricas do repositório
- Stars
- (384 estrelas)
- Métricas de merge de PR
- (Nenhuma PRs mesclada em 30d)
Description
I have some tests in my django projects that are hanging at both the self.broker.join('default') and self.worker.join() lines. I know that it hangs at the self.worker.join() line because I added a try/except block around the self.broker.join('default', timeout=5000) with the timeout added. These tests rely on my django views to send() to the dramatiq tasks in tasks.py.
I added print statements at the beginning and end of all of my actor tasks and I see them print when the timeout is reached.
I have some other tests that send() to the tasks directly and those tests are working perfectly.
I am using the StubBroker in my settings.
If I run the rabbitmq broker with a worker and manage.py runserver, I can see all of the tasks are executing successfully.
Do you have any suggestions on how to troubleshoot this?