Dzmitry-S
08/22/2024, 2:20 PMMarvin
08/22/2024, 2:21 PMpersist_result
parameter at both the flow and task levels. You can manually set persist_result=True
to ensure that results are persisted.
- For example:
from prefect import flow, task
@task(persist_result=True)
def my_task():
return 42
@flow(persist_result=True)
def my_flow():
result = my_task()
return result
Source: Prefect Documentation - Persistent Results
2. Subflow Execution:
- Subflows inherit configuration from the parent flow unless otherwise specified. This includes result persistence settings.
- If the parent flow does not persist results, you may need to explicitly configure the subflow to persist results.
3. GitHub Discussions:
- There was no direct mention of this specific issue on GitHub. However, you can check related discussions and updates which may provide additional insights:
- Add configuration of results
Given these points, I would recommend explicitly configuring both your parent and subflows to persist results if you are facing issues during retries.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.
Powered by