并行化应用后熊猫groupby

我使用了rosetta.parallel。Pandas_easy并行化后应用组by，例如:

从rosetta.parallel。pandas_easy进口groupby_to_series_to_frame

df = pd。DataFrame ({a: 6, 2, 2, b:(4、5、6)},指数= (g1, g1, g2的))

groupby_to_series_to_frame (df, np。mean, n_jobs=8, use_apply=True, by=df.index)

然而，有人知道如何并行化一个返回数据帧的函数吗?正如预期的那样，这段代码对于rosetta来说失败了。

def tmpFunc (df):

df = df(“c”)。+ df.b

返回df

df.groupby (df.index)苹果(tmpFunc)

groupby_to_series_to_frame(df, tmpFunc, n_jobs=1, use_apply=True, by=df.index)