https://prefect.io logo
Title
s

Slackbot

12/07/2022, 6:26 PM
This message was deleted.
s

Shirley Monroe

12/07/2022, 6:28 PM
I have a flow annotated with
@flow(result_storage='s3/my-block')
, and I have a deployment built from that flow. No storage-block or infrastructure-block on the deployment. I'll call this one
my_subflow
I have a local k8s cluster with an agent running & access to the deployment
Then I have an async wrapper for
my_subflow
that does this:
res = await run_deployment(...)
return res.state.result()
The return value here is always
None
, although
my_subflow
returns a non-null value.
And finally I have another flow that does this:
await gather(*(async_run_subflow(id) for id in ids))
The subflows are running, I can see them on both k8s and the prefect console, but the return values are nowhere & there's nothing on s3 at the path specified in the block. What am I missing?