- Big internal refactor:
- Reduces the risk of potential zombie workers
- New internal Worker and Supervisor classes which make code more readable / maintainable.
- Code is now split into individual files for each API function to make contribution easier and improve maintainability.
- API Reference docs are now shown per function and a new Overview page was created per module.
maxsize
arguement is removed from allfrom_iterable
functions as it was not used.worker_constructor
parameter was removed from allfrom_iterable
functions in favor of the simpleruse_thread
argument.
ordered
function in all modules, this orders output elements based on the order of creation on the source iterable.- Additional options and rules for the depending injection mechanism. See Advanced Usage.
- All
pl.*.Stage
classes now inherit frompl.BaseStage
.
timeout
parameter to most funtions in all modules, this stops code execution after a given amount of time if the task has not been completed.
sync
module which follows Pypeln's API but executes everything synchronously using python generators, meant for debugging purposes.
- Fixed critical bug (#29) related to
**kwarg
arguments created inon_start
not being passed toon_done
.