Контекст: Я использую пользовательские dask графики для управления и распространения вычислений.
Проблема: Некоторые задачи включают чтение в файлахкоторые производятся вне dask и не обязательно доступны во время вызова dask.get(graph,result_key).
Вопрос: Задание ожидания ввода-вывода файлов не является вариантом, так как это блокируетработников.Есть ли (или который был бы) хороший способ позволить dask ждать, пока файлы станут доступными, и только затем выполнять задачи ввода-вывода?
Большое спасибо за любые мысли!