I have a task (

task_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?

In this scenario, I think you can use a trigger with

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