Yardena Meymann
08/07/2022, 7:09 AMAnna Geller
from prefect.engine.results import GCSResult
gcs_result = GCSResult(bucket='prefect_results', location='{flow_name}__{task_name}_xxx.pickle')
@task(result=gcs_result)
def my_task():
...
Anna Geller
Yardena Meymann
08/07/2022, 1:27 PM