Queue assignment via decorator apply_async doesn't work

[dedfriedly]

Hi, small other issue here but the apply_async function in the custom task decorator doesn't properly apply routing if a queue is defined. Tested and verified locally. I believe this could be as simple as adding a queue=None to the apply_async object method.

[steinitzu]

Hmm the arguments should all be forwarded to base apply_async.
Can you provide a runnable code example to reproduce this?

[dedfriedly]

Pretty simple, just setup a custom queue consumer (celery -A project worker -Q "blah") and then I tried to push the singleton (decorator @app.task(base=Singleton, queue="blah") to the worker but task never showed up. If I'm being transparent, I can't be 100% sure it wasn't a worker issue but I did test for a while and it seemed consistent to me so wanted to open this.