Kyle McEntush
08/22/2020, 4:38 PMValueError: Could not infer an active Flow context.
Chris White
08/22/2020, 5:34 PM@task
def task_one():
pass
@task
def task_two():
task_one() # will raise an error, always
Kyle McEntush
08/22/2020, 6:22 PMChris White
08/22/2020, 6:23 PM.map
successively to create longer mapped pipelines, e.g.,
with Flow("my-mapped-flow") as flow:
task_three.map(task_two.map(task_one))
Kyle McEntush
08/22/2020, 6:27 PMChris White
08/22/2020, 6:27 PMKyle McEntush
08/22/2020, 6:34 PMChris White
08/22/2020, 6:35 PMTriggerFailed
state, but other branches of the map will continue uninterrupted