TypeError пытается объединить списки в Dask

Question

Как я могу объединить ряд списков в Dask?

Следующий код, использующий da.concatenate, приводит к этой ошибке:

TypeError: объект 'float' не может быть интерпретированкак целое число

import dask.dataframe as dd
import dask.array as da
def concat_lists(s):

    # Binarize connectors
    tmp = da.concatenate(s.values)

    return tmp

concat_lists(dd.from_pandas(pd.Series([["1","2"], ["1"], ["3", "2"], ["1"]]), npartitions=1)).compute()

Желаемым результатом будет один массив или серия dask, например ["1", "2", "1", "3", "2", "1"] Спасибо заранее

Answer 1

Функция da.concatenate использует список массивов dask и создает один массив dask, который объединяет их все.

Похоже, вы даете ему один массив dask, а не список, что и является причиной ошибки.Я подозреваю, что вы можете искать другую функцию, чем da.concatenate