v0.1.0

What's Changed

• Add Multiprocess Maybe by @Wason1797 in #10

Full Changelog: https://github.com/Wason1797/QueueAutomator/commits/v0.1.0

V0.0.2

What's Changed

• Fix potential issue with using a dictionary instead of a tuple to keep track of processes per queue

V0.0.1

This is the first release of queue-automator

Features:

• Create multiprocessing pipelines of any length easily
• A simple to use decorator API that registers your working functions

from queue_automator import QueueAutomator

# Create an instance of QueueAutomator()
automator = QueueAutomator()

@automator.register_as_worker_function(process_count=2)
def do_work(item: int) -> int:
    sleep(2)
    result = item*2
    return result

if __name__ == '__main__':
    input_data = range(30)

    # Always set your input data before calling .run()
    automator.set_input_data(input_data)
    results = automator.run()
    print(results)