Same problem here with my graph having a double-nested map-reduce pattern, where A -> Send([B, C])
and B -> Send([D, E])
with C -> A
and D -> A
and E -> A
The problem manifests as:
Node A doesn't wait for all edges (D, E, and C) to complete before starting
A can be triggered with only C completed, then again with D and E
This violates the expected map-reduce behavior where the reduce phase should collect all results before proceeding
I tried also to set the parameter defer=True
for the A node as advised in the doc, but still have the same issue.