An Hoang
02/17/2022, 5:02 AMtask_B
) downstream of a mapped task (task_A
). Some of the input for task_B
(output of task_A
) is prefect.engine.signals.SKIP(None)
. In task_B
, do I have to filter out these skip signals? If output of task_B
is mapped to task_C
... task_X
, do I have to do if isinstance(input, prefect.signals.SKIP): raise prefect.signals.SKIP
for every single task in the chain?Kevin Kho
always_run
if you want it to run even is task_A
is skipped. So no you don’t need to filter them out. There is also skip_on_upstream_skip
that can be declared on the task