S

SiftZendeskTest

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: ```@dynamic def my_dynamic_wf(): results = [] ... Create some chunks of task inputs ... for c in chunks:```

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:```
Status
open
Tags
    Source
    #ask-the-community