I have a task (`task_B`) downstream of a mapped ta...
# ask-community
a
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?
k
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