Hi all, I have a task/dynamic task task that polls a directory looking for event files and then launches another dynamic task. The problem Im running into is that is looks like these tasks don't get launched until my initial dynamic task ends. So for example Im doing something like:

@dynamic
def poll_and_launch():
    start = time()
    while time() - start > 200:
       if new_file_exists():
             launch_other_task(some_file_Dependent_stuff)

The

launch_other_task

tasks dont get launched until after 200s (i.e. the

poll_and_launch

task has exited)