dask ошибка вычисления кадра данных после нескольких примененных функций - PullRequest
0 голосов
/ 28 февраля 2019

У меня огромный фрейм данных dask с npartitions = 8, я применил несколько функций для создания новых столбцов и очистки / преобразования данных, как показано ниже:

  dd.abc.apply(abc_filter, meta = 'str')

После этого, когда я выполняю dd.compute ()Я получил KeyError и cancellederror в tracestack

  KeyError: "('assign-d503d4a91b5f244a3868f400a8ae6974', 0)"
  . 
  .
  CancelledError: ('assign-d503d4a91b5f244a3868f400a8ae6974', 0)

Я могу добавить весь след, если это поможет!

...