itay livni
02/24/2020, 7:07 PMtask
in a Flow
that takes a list
. How do I set rhe List
Trigger
to run on any_successful
upstream tasks?
https://docs.prefect.io/core/concepts/tasks.html#collections
I tried a couple approaches including def_list = List(trigger=any_successful) and then calling
munged_defs_df = definitions.munge_dfs(def_list([df1, df2, df3])
Alex Goodman
02/24/2020, 7:25 PMimport prefect
from prefect.tasks.core.collections import List
@prefect.task()
def a_task():
raise prefect.engine.signals.FAIL
@prefect.task()
def b_task():
pass
@prefect.task()
def c_task():
pass
@prefect.task()
def d_task():
pass
def_list = List(trigger=prefect.triggers.any_successful)
with prefect.Flow("My Flow") as flow:
flow.chain(a_task, def_list(b_task, c_task), d_task)
flow.visualize(flow.run())
itay livni
02/24/2020, 7:28 PMAlex Goodman
02/24/2020, 7:31 PMList
itay livni
02/24/2020, 7:40 PMList
Alex Goodman
02/24/2020, 7:40 PM