George Psarakis

@alukach a few questions here: - Why did you need a custom worker implementation? To integrate it as a Django command with `manage.py` ? - How do you know that...

@alukach have you tried perhaps sub-classing the [WorkController class](https://github.com/celery/celery/blob/master/celery/worker/worker.py#L64) instead of `ConsumerMixin`? If you notice it does use [Hub](https://github.com/celery/celery/blob/master/celery/worker/worker.py#L82) in the list of bootsteps so I am guessing it will...

Hello @chadrik . Sounds useful, can you give a brief outline on how you have designed this feature?

Redis documentation states that this operation should be close to `O(1)`. Your solution looks good to me.

@pitervergara can you share your Celery configuration, mostly the broker you are using (RabbitMQ, Redis etc) ?

@skeezus `AsyncResult.revoke` runs `control.revoke` internally, thus I see no difference in implementation there. @mmrobins does this happen on individual tasks or you are using chain/group or some other Canvas workflow?

I tried to reproduce the issue: ```python from celery import Celery, chain app = Celery(broker='redis://', backend='redis://127.0.0.1/') @app.task def add(x, y): return x + y def run(): return (add.s(5,6) | add.s(10)...

@jenstroeger the principle seems the same. Also I wanted to make clear the `revoke` functionality. I noticed this though on your code (https://github.com/celery/celery/issues/4299): ```python result = _do_otherthing.AsyncResult(task_id) ``` Are you...

@jenstroeger generally you cannot delete messages from an AMQP broker. Celery tries to work around this, by providing the `revoke` functionality, which, as you can imagine, is not trivial to...

@auvipy https://www.celeryproject.org does not work.