通过射线问题并行

Question

    @ray.remote
    def parallel1(a):
        Gbr1 = ExponentialSmoothing(endog=series1['Price'],trend = True,damped_trend = True).fit(disp = False)
        pr1 = list(Gbr1.forecast(136).values)[-1]
        return pr1
    @ray.remote
    def parallel2(a):
        Gbr2 = ExponentialSmoothing(endog=series2['Price'],trend = True,damped_trend = True).fit(disp = False)
        pr2 = list(Gbr2.forecast(90).values)[-1]
        return pr2
    x_id = parallel1(-1).remote()
    y_id = parallel2(-1).remote()
    pr1,pr2 = ray.get([x_id,y_id])

尝试并行化此代码但出现错误：TypeError: Remote functions cannot be called directly. Instead of running '__main__.parallel1()', try '__main__.parallel1.remote()'

ray 库是通过 pip 安装的

Answer 1

尝试

x_id = parallel1.remote(-1)
y_id = parallel2.remote(-1)

通过射线问题并行

Paralleling via ray issue

python

ray