import pandas as pd
from step import step
import ray
ray.init()

filepath = "D:/python_project_data/1.csv"
origin_data = pd.read_csv(filepath)
row_len = origin_data.shape[0]
cow_len = origin_data.shape[1]
disturb_data = origin_data
algorithm_step = step.remote()
cow_name = "G1.TTXD1_3"
algorithm_step.set_config.remote('{"STEP_AMPLITUDE_BASE": 1.3}')
for i in range(0,row_len):
    futures=algorithm_step.eval.remote(origin_data.loc[i,cow_name])
    disturb_data.loc[i, cow_name] = ray.get(futures)
print(disturb_data.loc[:,cow_name])