Невозможно заменить раздел серии Dask - PullRequest
Новая
       38

Невозможно заменить раздел серии Dask

0 голосов
/ 03 июля 2018

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

list_of_delayed = dask_df.to_delayed()
new_partition = dask.delayed(pd.read_csv)(filename)
list_of_delayed[i] = new_partition
new_dask_df = dd.from_delayed(list_of_delayed, meta=dask_df._meta)

Я сделал то же самое, за исключением того, что dask_df - это серия в моем случае. Я получаю следующую ошибку: 

Traceback (most recent call last):
File "sdfr_dhruvkmr.py", line 465, in <module>
    pts = task[(task.task_date <= dtm.Time.iloc[i]) & (task.T_Date == dtm.Date.iloc[i])]
  File "/usr/lib/python2.7/site-packages/edask/dataframe.py", line 130, in __getitem__
    new_dask_df = dd.from_delayed(list_of_delayed)
  File "/usr/lib/python2.7/site-packages/edask/edask/dask/dataframe/io/io.py", line 493, in from_delayed
    type(df).__name__)
TypeError: Expected Delayed object, got Delayed
...