В каком порядке распределяются задачи Выполненные задачи

Предполагая код, подобный этому

def square(x):
    import time
    time.sleep(60)        
    return x ** 2
def neg(x):
    import time
    time.sleep(60)           
    return -x


A = client.map(square, range(10))
B = client.map(neg, A)
total = client.submit(sum, B)

total.result()

Как Dask распределяет задания по расписанию? Это начинается сверху вниз? или снизу вверх? Работает ли распределенный Dask в DFS или BFS Могу ли я добавить задачи приличия, которые не являются частью оцениваемой функции? например добавление задачи C

C = client.submit(foo,args)

И заставить С бежать после А, но до В

0 ответов

Другие вопросы по тегам