Untitled

@flow
def dependency_flow():
    # Two tasks run in parallel
    future_a = task_a.submit()
    future_b = task_b.submit()

    # Task C waits for A and B results
    future_c = task_c.submit(future_a, future_b)

    # Task D runs regardless of C's success/failure
    future_d = task_d.submit(wait_for=[future_c])

    return future_d