У меня огромный фрейм данных dask с npartitions = 8, я применил несколько функций для создания новых столбцов и очистки / преобразования данных, как показано ниже:
dd.abc.apply(abc_filter, meta = 'str')
После этого, когда я выполняю dd.compute ()Я получил KeyError и cancellederror в tracestack
KeyError: "('assign-d503d4a91b5f244a3868f400a8ae6974', 0)"
.
.
CancelledError: ('assign-d503d4a91b5f244a3868f400a8ae6974', 0)
Я могу добавить весь след, если это поможет!