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.