В каком порядке распределяются задачи Выполненные задачи
Предполагая код, подобный этому
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)
И заставить С бежать после А, но до В