search

python-arq / arq

Fast job queuing and RPC in python with asyncio and redis.
https://arq-docs.helpmanual.io/
MIT License
2.15k stars 174 forks source link

job.result() hangs indefinitely if queue_name other than "arq:queue" is used #390

Closed AlexanderPodorov closed 1 year ago

AlexanderPodorov commented 1 year ago

In WorkerSettings: If queue_name = "arq:queue" is used, then everything works as expected. In case if I take e.g. arq:queue:something, job.result() hangs indefinitely. Looks like "arq:queue" name is hardcoded somewhere causing this issue. Nevertheless, thanks for this awesome library!

JonasKs commented 1 year ago

Can you provide a reproducible example?

Seems to me that the queue is passed along: https://github.com/samuelcolvin/arq/blob/main/arq/connections.py#L171

AlexanderPodorov commented 1 year ago

Ah, yes, I did not set _queue_name of enqueue_job method, so it took the default queue name. I just set queue name in WorkerSettings. If the issue is actually the expected behavior, I can close this issue.

JonasKs commented 1 year ago

That is the expected behavior indeed 😊 you can have multiple workers and queues.

AlexanderPodorov commented 1 year ago

Got it, thanks, issues is closed