- Breaking: Default engine changed from
threading.Threadtomp.Process[a3dc1af]
- Correct annotations and docstrings [7a2470a]
- rename from
ezpqtoppqueue - replaced
queue.getwithqueue.dequeue/queue.pop queue.putis an alias forqueue.enqueue- renamed
queue.emptytoqueue.is_empty - renamed
queue.fulltoqueue.is_full - renamed
queue.count_queuestoqueue.sizes - replaced
ezpq.FinishedJobwithezpq.Job job.outputis nowjob.resultjob.callbackis nowjob.callback_result- wrapped
Plot(...).build(...)into justplot_jobs(...) - use of enums to constrain plot parameter choices
- bump dependencies
clear_waiting()function to clear the waiting queue.- Added
stop_on_lane_errorparameter toezpq.Jobto allow for short-circuiting a synchronous lane if a job in the lane fails. When set toTrueand the preceding job has a non-zero exit code, this job will not be run. Note that this is to be set per-job for flexibility. - Additional unit tests.
stop_all()function now clears the waiting queue and terminate running jobs. This addresses a bug where a queue would fail to close when disposing with jobs still in the waiting queue.- The default
pollfor the queue itself is still0.1. Now, the defaultpollforgetandwaitis equal to thepollfor the queue itself, as it makes no sense to check for changes more freqeuntly than changes could arise.
- Removed functions
has_waiting,has_work, andhas_completed. Usesize(...)for this. - Renamed
Queue.is_startedtoQueue.is_running.
- Added
map()function toezpq.Queue. - Integration with tqdm package for progress bars.
- Added
laneproperty toezpq.Job. When set, jobs in the same lane are processing sequentially. - Added
exceptionproperty toezpq.Job. Stores the exception of a failed job. - Added
suppress_errorsparameter toezpq.Job. - Added
facet_by,theme, andcolor_palparameters toezpq.Plot.build(). - Added
qid(queue id) to job data output. This can be used to facet anezpq.Plot. - Unit tests.
- Removed parameter
nfrom thewait()function ofezpq.Queue;wait()will halt execution until all jobs in the queue are processed. - Moved
ezpq.Plot()plotting parameters toezpq.Plot.build(). - Reordered
ezpq.Queue()init parameters.
- Initial release