Рабочие постоянные переменные Dask

Question

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

Answer 1

Рабочие сами по себе являются процессами Python, поэтому вы можете делать трюки с помощью globals().

Однако, возможно, более чистые, чтобы испускать значения и передавать их между задачами. Dask сохраняет за собой право повторять функции и запускать их на разных машинах, поэтому в зависимости от глобального состояния или состояния, характерного для конкретного штата, вы можете легко попасть в неприятности.