Asynchronous pipeline builder
Project description
Coroflow
This is a library for building asynchronous coroutine-based pipelines in Python. Useful features include:
- pass data between tasks with queues
- Connect stages of the pipeline with fanout/fanin patterns or load-balancer patterns
- mix in blocking taks, coroflow will run it in threads
- has an apache ariflow like api for connecting tasks
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
coroflow-1.0.2.tar.gz
(5.2 kB
view hashes)