kombu: Broadcast does not work with Redis broker
Checklist
- I have included the output of
celery -A proj report
in the issue. (if you are not able to do this, then at least specify the Celery version affected). - I have verified that the issue exists against the
master
branch of Celery. - tested against latest Celery v4.2.1
Steps to reproduce
I have prepared minimal reproduce sampes and their output here: https://gist.github.com/andreyst/2ae51dcb568ce789e080fb8259b5bbc7
Expected behavior
I expect that task sent to broadcast queue will be executed by every launched worker.
I expect broadcast to work in Redis broker because it is mentioned on Redis broker page here: http://docs.celeryproject.org/en/latest/getting-started/brokers/redis.html#caveats
Actual behavior
Task sent to broadcast queue is not received and not executed by any launched worker using Redis broker. Changing broker to RabbitMQ and not touching anything else works as expected.
About this issue
- Original URL
- State: closed
- Created 6 years ago
- Comments: 15 (7 by maintainers)
@auvipy I tried installing
celery
from master (https://github.com/celery/celery.git) andkombu
from #1122 (https://github.com/LeetCode-OpenSource/kombu.git) and can confirm that a minimal check like that mentioned here does not throw an exception.