(please find Lib/queue.py for the actual implementations of Queue, PrioirtyQueue and LifoQueue.)Įxcept for Queue class, other classes looked straight forward to enhance for this purpose. Python comes with a built-in PriorityQueue class, contained in the queue module. I looked into the implementation of queue module and found that queues in each classes are implemented as the following types: In Erlang, there is a method queue:from_list/1 that initialize a queue from a list in O(1). Its arguments and keyword arguments will be kept in the Job. To retry, you can manually re-invoke your function, send the failed event to a queue.

How about enhancing queue.XXXQueue classes to accept a list on initializing a queue, which works in O(1) (if possible)? I assume an interface something like: l = # existing list AWS Lambda function errors in Python AWS Lambda. If timeout is a positive number, it blocks at most timeout seconds and raises the queue.Empty exception if no item was available within that time. It depends on the availability of thread support in Python see the threading. I am writing a code that uses queues and lists, and every time I need to create a queue from a list, what I do is l = # existing list The Queue class in this module implements all the required locking semantics.

Python queue methods