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)

Most upvoted comments

@auvipy I tried installing celery from master (https://github.com/celery/celery.git) and kombu 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.