多次调用 compute() 时出现 Dask 错误

Question

我正在使用dask，我需要先使用compute() 执行转换才能继续工作流程。在第二次转换期间似乎对象的类型发生了变化并且正在引发错误'DataFrame' object has no attribute 'compute'

我当前的代码如下：

newtypes = {"age":int, "is_superuser":bool}
df = df.astype(newtypes).compute()
# ....
# 
....
strtypes = {"age":str, "is_superuser":str)
df = df.astype(strtypes).compute() # Here is raised the exception. 

Answer 1

如 cmets 中所述，您的第二个数据帧实际上是 Pandas 数据帧，而不是 Dask 数据帧，因此您不需要第二次调用 .compute()。