Hi everybody, i am wondering for the

transform task

, it is expected to fail for parameter

"a"

, but when i rerun from fail, what is the expected flow? Will it rerun for all cases

[3,1,"a"]

or skip

3,1

, and only rerun

a

@task
def extract():
    return [3, 1, "a"]


@task
def transform(x):
    y = x + 1
    logger = prefect.context.get("logger")
    <http://logger.info|logger.info>(y)
    return y


with Flow("failure-flow-test", executor=LocalExecutor(), run_config=LocalRun()) as flow:
    e = extract()
    t = transform.map(e)

Hi @Jeremy Tee -- to skip the successful tasks you'll need to define a

Result

type to cache the results for those tasks. See https://docs.prefect.io/core/concepts/persistence.html#persisting-output and https://docs.prefect.io/core/concepts/results.html#result-objects

thank youi!