<div dir="ltr">Hi,<div><br></div><div>I&#39;m trying to implement a priority queue over Rabbit with python, and this is my idea</div><div>each batch of tasks has its own queue, each worker knows about all the batches and their priorities.</div>
<div>now the part where I don&#39;t understand:</div><div>  how does a worker tries a take a task from a batch(queue)  but if its empty it passes to the next batch?</div><div><br></div><div>I need somthing like:</div><div>
<br></div><div>for q in queuesSortedByPriority:</div><div>  t = q.get()</div><div>  if t: break</div><div>else: raise NoTaskFound()</div><div><br></div><div>Many thanks,</div><div><br></div><div>Yoav Glazner.</div><div><br>
</div></div>