Я пытаюсь прочитать от каждого работника уникальный локальный файл, однако я получаю одинаковый результат для всех работников, а не уникальный результат от каждого работника ... Может кто-нибудь указать, что я делаю неправильно ?
from dask.distributed import Client, progress
c = Client()
c
import dask.dataframe as dd
filename_1='/tmp/1990.csv'
filename_2='/tmp/1991.csv'
filename_3='/tmp/1992.csv'
future_1 = c.submit(dd.read_csv,filename_1 , workers='172.18.0.3')
future_2 = c.submit(dd.read_csv,filename_2 , workers='172.18.0.5')
future_3 = c.submit(dd.read_csv, filename_3 , workers='172.18.0.6')
future_1.result().head()
future_2.result().head()
future_3.result().head()
Я получу тот же результат вместо уникальных данных от каждого из них.