a

    An Hoang

    7 months ago
    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?
    Kevin Kho

    Kevin Kho

    7 months ago
    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