Matthew Roeschke04/28/2022, 10:21 PM
. I added
to this task I got this Userwarning I don’t really know how to addressed based on the link. I thought I could pass the results from a functional task to another task?
UserWarning: Task <...> has retry settings but some upstream dependencies do not have result types. See <https://docs.prefect.io/core/concepts/results.html> for more details.
Here is explanation from the docs: "For example, suppose task A is configured to use result A, and task B to use result B, and that A passes data downstream to B. If B fails and requests a retry, it needs to cache its inputs, one of which came from A. If you are using Cloud, Cloud will use results to persist the input cache, and since the data is from task A it will use the result configured on A."
from prefect import Flow, task from prefect.engine.results import PrefectResult @task(result=PrefectResult()) def my_task(): return 3 >>> state.result[first_result]._result.value 3 >>> state.result[first_result]._result.location '3'
@task(checkpoint=False) # to disable
Matthew Roeschke04/29/2022, 1:08 AM