Garret Cook
07/19/2021, 4:09 PMKevin Kho
07/19/2021, 4:11 PMGarret Cook
07/19/2021, 4:12 PMKevin Kho
07/19/2021, 4:30 PMGarret Cook
07/19/2021, 4:34 PMKevin Kho
07/19/2021, 4:35 PMGarret Cook
07/19/2021, 4:35 PMKevin Kho
07/19/2021, 4:38 PMfrom prefect import Flow, task
import prefect
from prefect.engine.signals import TRIGGERFAIL, FAIL
from prefect.tasks.control_flow.filter import FilterTask
fil = FilterTask(lambda r: not isinstance(r, BaseException))
@task
def abc(x):
if x == 2:
raise TRIGGERFAIL("test")
if x == 5:
raise FAIL("test")
return x
@task
def log(x):
logger = prefect.context.get("logger")
<http://logger.info|logger.info>(x)
return x
with Flow(" ") as flow:
x = abc.map([1,2,3,4,5,6,7,8,9])
x = fil(x)
log(x)
Garret Cook
07/26/2021, 2:41 AMKevin Kho
07/26/2021, 3:01 AM