Summary
Hi folks.. Question about map_tasks. I have a dynamic which triggers 2 map_tasks (same task really but to handle the fan out which is more than 5k). Earlier I would see both trigger simultaneously but in my most recent run I saw them getting serialized despite no dependency between them. Code looks like this:
def my_dynamic_wf():
results = []
...
Create some chunks of task inputs
...
for c in chunks:```