Как достать будущий предмет из сумочки?

Question

Мне нужно вызвать функцию обратного вызова из будущего, чтобы выполнить логику повторных попыток для задачи. Но я не знаю, как достать будущий предмет из сумочки.

Например, вот как используется сумка для сумок

b = db.from_sequence(['1.dat', '2.dat', ...]).map(process_filename)
b.compute()
# I need a callback function when a task is finish with a single file to have complex retry logic
# I can get a future object from client.submit(my_args).add_done_callback(my_call_back) but I don't want to use client.submit because of large data set

Answer 1

Вы можете получить фьючерсы из разделов мешка со следующим:

from dask.distributed import futures_of

b = b.persist()
futures = futures_of(b)