Hi there,
Does anyone know how I can directly read persisted results from storage? I tried the following:
Copy code
from prefect import flow
from prefect.results import get_result_store
@flow(persist_result=True)
def pipeline():
store = get_result_store()
result = store.read("my-key") # Where I know that a file corresponding to this key exists on disk
return result
if __name__ == "__main__":
pipeline()
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.