, 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
Shirley Monroe
12/07/2022, 6:28 PM
I have a local k8s cluster with an agent running & access to the deployment
Shirley Monroe
12/07/2022, 6:35 PM
Then I have an async wrapper for
my_subflow
that does this:
Copy code
res = await run_deployment(...)
return res.state.result()
The return value here is always
None
, although
my_subflow
returns a non-null value.
Shirley Monroe
12/07/2022, 6:37 PM
And finally I have another flow that does this:
Copy code
await gather(*(async_run_subflow(id) for id in ids))
Shirley Monroe
12/07/2022, 6:41 PM
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?
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.