Mitch
07/17/2024, 8:38 PMawaited = await asyncio.gather(*futures, return_exceptions=True)
in the parent flow, but my parent flows says completed even though the subflows are still in a running state. Why is this happening?Marvin
07/17/2024, 8:39 PMasyncio.gather()
, you might run into issues where the parent flow doesn't correctly track the state of these subflows.
It's worth noting that subflows behave like independent flow runs in the backend, and if spawned via deployments, they might not synchronize state updates back to the parent as expected.
For better control, ensure you're managing the states of these subflows properly, possibly by:
1. Monitoring subflow states directly.
2. Adding retries or state-checking mechanisms within the parent flow.
For more detailed information, you can refer directly to Prefect's documentation on flows and subflows.
If the problem persists, feel free to provide more specific details or consult this related GitHub issue for more context.Nate
07/17/2024, 9:06 PMMitch
07/24/2024, 6:36 PM