Клиент Dask успешно подключается, но рабочие процессы недоступны ⇐ Python

[Anonymous]

Я использую Dask для некоторой обработки. Клиент запускается успешно, но я не вижу ни одного работника.
Вот как я создаю клиент:

Код: Выделить всё

client = Client("tls://localhost:xxxx")

Это обрабатывающая часть кода:

Код: Выделить всё

start = time.perf_counter()

print(f"Submitting {len(root_files)} files to the cluster..")

futures = client.map(process_file, root_files)
results = client.gather(futures)

all_masses = np.concatenate(results)

elapsed = time.perf_counter() - start

print(f"Total events processed: {len(all_masses)}")
print(f"Processing time: {elapsed:.2f} s")

Клиент запускается, но рабочие процессы недоступны, поэтому ничего не работает.
Есть идеи, что я могу упустить?


Подробнее здесь: https://stackoverflow.com/questions/798 ... -available