-
-
Notifications
You must be signed in to change notification settings - Fork 294
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
broker_priority not work #553
Comments
When you init the broker, you need to add |
i did had max_priority=10 in my broke. but it not work.
|
Take into account that the worker takes the next available message. If you produce the messages at the same rate as you consume them, then your queue always has one message. |
Issues
I want to run tasks based on priority levels 。 but it not work
What OS are you using?
windows
What version of Dramatiq are you using?
Dramatiq 1.14.2 and i use Rabbitmq as Broker
What did you do?
i try two code to test the broker_priority ,but it does not work as i except
dramatiq --threads 2 --processes 2 _url -Q testfun
first i run
after it end i run
What did you expect would happen?
I want to run tasks based on priority levels
What happened?
It appears to be out of order at runtime and not arranged according to the priority order
Is it my misunderstanding that there is no such function ? and I did not see any information about the broker_priority document, please help me!!!
The text was updated successfully, but these errors were encountered: