Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.

Prefect Community

Are there any good examples of using signal.SKIP() to short circuit running the whole flow? Trying to wrap our brain around it. Example:

```def test_short_circuitted_flows(prefect_flow):
    @task
    def extract() -&gt; int:
        signal = signals.SKIP()
        signal.flag = True
        signal.value = "I was skipped yo!"
        raise signal

    @task(skip_on_upstream_skip=True)
    def transform(x: int) -&gt; int:
        return int(x / 2 + 2)

    @task(skip_on_upstream_skip=True)
    def load(x: int) -&gt; str:
        return str(x)

    with prefect_flow as flow:
        e = extract()
        t = transform(e)
        l = load(t)

    assert is_serializable(flow)

    state = flow.run()

    assert state.is_successful()

    assert state.result[e].is_successful()
    assert state.result[t].is_successful()
    assert state.result[l].is_successful()

    assert isinstance(state.result[e].result, signals.SKIP)
    assert isinstance(state.result[t].result, signals.SKIP)
    assert isinstance(state.result[l].result, signals.SKIP)```

```   assert isinstance(state.result[t].result, signals.SKIP)
E   assert False
E    +  where False = isinstance(None, &lt;class 'prefect.engine.signals.SKIP'&gt;)
E    +    where None = &lt;Skipped: "Upstream task was skipped; if this was not the intended behavior, consider changing `skip_on_upstream_skip=False` for this task."&gt;.result
E    +    and   &lt;class 'prefect.engine.signals.SKIP'&gt; = signals.SKIP```

just trying to verify that t and l tasks were skipped

image.png

ah, the result is a state object, not a signal object

final working example. thanks for listening :wink:

```def test_short_circuitted_flows(prefect_flow):
    @task
    def extract() -&gt; int:
        signal = signals.SKIP()
        signal.flag = True
        signal.value = "I was skipped yo!"
        raise signal

    @task(skip_on_upstream_skip=True)
    def transform(x: int) -&gt; int:
        return int(x / 2 + 2)

    @task(skip_on_upstream_skip=True)
    def load(x: int) -&gt; str:
        return str(x)

    with prefect_flow as flow:
        e = extract()
        t = transform(e)
        l = load(t)

    assert is_serializable(flow)

    state = flow.run()

    assert state.is_successful()

    assert state.result[e].is_successful()
    assert state.result[t].is_successful()
    assert state.result[l].is_successful()

    assert isinstance(state.result[e], Skipped)
    assert isinstance(state.result[t], Skipped)
    assert isinstance(state.result[l], Skipped)```