Python library for dataflow programming.
e4bf50a Update tests: check on_failure callback on each failed workflow