Workflow.__call__(iter_, success_callback=None, fail_callback=None)[source]

Operate on all the data

State: Experimental as of 0.4.0.

This is the processing engine of the workflow. Callbacks are executed following applying all workflow methods to an item from iter_ (unless short_cicruit=True in which case method execution for an item is stopped if failed=True). Callbacks are provided self which allows them to examine any aspect of the workflow.


it : an iterator

success_callback : method to call on a successful item prior to

yielding. By default, self.state is yielded.

fail_callback : method to call on a failed item prior to yielding. By

default, failures are ignored.