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.
| Parameters: | it : an iterator success_callback : method to call on a successful item prior to
fail_callback : method to call on a failed item prior to yielding. By
|
|---|