Evan Curtin
08/26/2021, 3:34 PM@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]
def rating_model_backtest_workflow(opts: dict):
with Flow("local-results") as flow:
downstream_task(root_task)
flow.run()
I’m running this from the docs, I am expecting files to show up at ./initial_data.prefect
and the other location, but nothing appears, am I missing something obvious?Evan Curtin
08/26/2021, 3:43 PM~/prefect/results/./test_root.prefect
which was rather surprisingKevin Kho
Evan Curtin
08/26/2021, 3:51 PMEvan Curtin
08/26/2021, 3:51 PM[2021-08-26 10:33:36-0500] INFO - prefect.FlowRunner | Beginning Flow run for 'local-results'
[2021-08-26 10:33:36-0500] INFO - prefect.TaskRunner | Task 'root_task': Starting task run...
[2021-08-26 10:33:36-0500] INFO - prefect.TaskRunner | Task 'root_task': Finished task run for task with final state: 'Success'
[2021-08-26 10:33:36-0500] INFO - prefect.TaskRunner | Task 'downstream_task': Starting task run...
[2021-08-26 10:33:36-0500] INFO - prefect.TaskRunner | Task 'downstream_task': Finished task run for task with final state: 'Success'
[2021-08-26 10:33:36-0500] INFO - prefect.FlowRunner | Flow run SUCCESS: all reference tasks succeeded
Kevin Kho
Evan Curtin
08/26/2021, 3:56 PMKevin Kho
@task(checkpointing=True)
Evan Curtin
08/26/2021, 4:00 PM