Task Priority as Parameter


Hi! I need to define priority for different tasks. All tasks execute the same function with different parameters, and priority depends on parameters. Is there a way to define a priority as a parameter? Or should I define one actor per task, with the priority desired?


Priority is currently only at the actor level at the moment. Also recognize that the priority is only applied once the message reaches the worker, so you’ll need to use different queues as well in order to ensure that high priority messages don’t get stuck behind low priority messages in the broker.

Disclaimer: I’m new to the project. But I have been reading the code, and this is my current understanding.