Philip MacMenamin
06/19/2020, 5:39 PMnicholas
06/19/2020, 5:44 PMPhilip MacMenamin
06/19/2020, 5:46 PMnicholas
06/19/2020, 5:49 PMPhilip MacMenamin
06/19/2020, 5:53 PMnicholas
06/19/2020, 5:57 PMPhilip MacMenamin
06/19/2020, 5:57 PMnicholas
06/19/2020, 6:07 PMPhilip MacMenamin
06/19/2020, 6:11 PMnicholas
06/19/2020, 6:14 PMPhilip MacMenamin
06/19/2020, 6:26 PMnicholas
06/19/2020, 6:32 PMprefect.context
is available in every task, you'd be able to persist the final results in the remote location using the same variables you would in a templated locationPhilip MacMenamin
06/19/2020, 6:35 PMnicholas
06/19/2020, 6:36 PMPhilip MacMenamin
06/19/2020, 6:37 PMfrom prefect import task, Flow
from prefect.engine.results import LocalResult
@task(result=LocalResult(location="initial_data.prefect"))
def root_task():
return [1, 2, 3]
@task(result=LocalResult(location="{date:%A}/{task_name}.prefect"))
def downstream_task(x):
return [i * 10 for i in x]
with Flow("local-results") as flow:
downstream_task(root_task)
What should this snippet do?nicholas
06/23/2020, 8:49 PMPhilip MacMenamin
06/23/2020, 8:49 PM