Philip MacMenamin
06/19/2020, 5:39 PMnicholas
Philip MacMenamin
06/19/2020, 5:46 PMPhilip MacMenamin
06/19/2020, 5:48 PMnicholas
Philip MacMenamin
06/19/2020, 5:53 PMPhilip MacMenamin
06/19/2020, 5:54 PMnicholas
Philip MacMenamin
06/19/2020, 5:57 PMPhilip MacMenamin
06/19/2020, 6:00 PMPhilip MacMenamin
06/19/2020, 6:04 PMnicholas
Philip MacMenamin
06/19/2020, 6:11 PMnicholas
Philip MacMenamin
06/19/2020, 6:26 PMPhilip MacMenamin
06/19/2020, 6:30 PMnicholas
nicholas
prefect.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 PMPhilip MacMenamin
06/19/2020, 6:36 PMnicholas
Philip MacMenamin
06/19/2020, 6:37 PMPhilip MacMenamin
06/23/2020, 8:15 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?Philip MacMenamin
06/23/2020, 8:16 PMnicholas
Philip MacMenamin
06/23/2020, 8:49 PM