Dynamic queue name for all brokers

[FlorianLB]

Complement to #94 , some brokers were missing the feature.

[FlorianLB]

@s3rius any chance you can review it (and make a release) soon ?

we are missing this feature to build a proper priority queue system

[chandr-andr]

@FlorianLB Hi! I can, s3rius on the vacation now.

Could you please check tests? They failed.

[chandr-andr]

@FlorianLB, and please add some information about your PR in the repo's README.

[FlorianLB]

@chandr-andr I documented the changes.

But tests are failing because of the test pipeline setup, not due to the changes

[chandr-andr]

@FlorianLB Ok, thanks! I'll make a release now

[chandr-andr]

@FlorianLB https://pypi.org/project/taskiq-redis/1.1.1/
You can check it here

[vkozmik]

@FlorianLB could you please explain how to use it for low priority queue? E.g. how to configure a worker to consider that one queue has bigger priority than the other?

[FlorianLB]

@vkozmik

how to configure a worker to consider that one queue has bigger priority than the other?

You can't right now. You have two options with the current state of the library :

• having X different instances of the worker, each configured for a specific queue
• with only one worker, use the additional_streams parameter to do a kind of round-robin between the main stream and the additional stream. It's not a true priority system but it works good enough for a case where your low priority queue has way more volume than the default one.

[vkozmik]

Thank you for the information!