Hi! I have a loop which runs task_a and then task_b, but want to skip task_b depending on the result of task_a. See code below:

for i in range(x):
    task_a_result = task_a.submit(i)
    if task_a_result.result() == "do_task_b":
       task_b.submit(task_a_result)

It seems that doing task_a.result() blocks the for loop, is there a way to do this logic concurrently? Or I should have task_b handle different types of results of task_a instead?

Something worth trying. If you use async and a result queue, you can have task_a add the result to the queue. Another async func (not a task) is regularly polling for items in the queue. When it picks up a result that meets the condition, it submits task_b with the result.