Я установил контейнер с dask-планировщиком и несколькими рабочими контейнерами на разных машинах....

Я использую интенсивный код Python для ввода-вывода в Dask и хочу увеличить количество потоков на...

Я использую pytest для проверки своих рабочих процессов. У меня есть определенный рабочий процесс,...

Я работаю над приложением python, которое требует синхронизации данных между удаленным...

Каков наилучший способ для всех рабочих / планировщиков Dask понять модули Python собственного...

У меня есть проект, структурированный следующим образом: - topmodule/ - childmodule1/ - my_func1.py...

Я получаю предупреждающее сообщение «shared.utils_perf - ПРЕДУПРЕЖДЕНИЕ - полная сборка мусора...

У меня есть массив dask (distMap) измерения (329960, 4). Я пытаюсь применить следующие операции,...

При применении опции продолжительности жизни рабочих с перезапуском похоже, что если рабочий...

У меня есть тысячи файлов паркета, которые мне нужно обработать. Перед обработкой файлов я пытаюсь...

У меня есть кластер работников Dask, который я хочу использовать для распараллеливания операций...

Попытка отправить задачу работнику и вернуть результаты.Однако необходимо выполнить сборку мусора...

В настоящее время я работаю над рефакторингом некоторой устаревшей аналитики в Python / DASK, чтобы...

У меня проблемы с изменением временного каталога в Dask.Когда я почему-то меняю временный каталог в...

У меня есть простой скрипт Dask-YARN, который выполняет только одну задачу: загрузите файл из HDFS,...

Я добавил пользовательский обратный вызов с помощью функции client.register_worker_callback (),...

Я пытаюсь запустить задание Dask в кластере YARN.Это задание для чтения и записи в HDFS с...

У нас есть задания, которые взаимодействуют с нативным кодом, и во время обработки задания...

Я пытаюсь выполнить пользовательский граф dask в распределенной системе, дело в том, что он,...

Есть ли способ получить диагностические данные Dask, кроме приборной панели для Dask.distributed...

У меня есть некоторый код вроде: x = delayed(add)(3, 2) y = delayed(add)(x, x) , и я хочу получить...

У меня есть распределенный массив dask с формой (2400,2400) с размером фрагмента (100,100).Я думал,...

Мне нужен способ получить список, содержащий конкретные данные столбца в Excel, но с ошибкой памяти...