Maybe I'm missing something obvious. Can't seem to persist my task/flow result. The folder
./test_prefect
is created but nothing is outputted. Here's my very simple code:
Copy code
## test_prefect.py
result = LocalResult(dir="./test_prefect")
@task(target="func_task_target.txt", checkpoint=True, result = result)
def test(val):
return val
with Flow("simple_test",result=result) as test_flow:
result = test(99)
test_flow.run()
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.