diff --git a/forloop/forloop_core.py b/forloop/forloop_core.py index 8102548..0918d0f 100644 --- a/forloop/forloop_core.py +++ b/forloop/forloop_core.py @@ -1,59 +1,56 @@ import requests import json -import pandas as pd class ForloopClient: def __init__(self, key=None, secret=None, url=None): self.key = key self.secret = secret - #self.session = requests.Session() if url: self.url = url else: self.url = "https://www.forloop.ai" - + + def execute_pipeline(self, user_email: str, pipeline_name: str): + url = f'{self.url}/api/v1/execute_pipeline' + + payload = { + "name": pipeline_name, + "user_email": user_email + } + + response = requests.post(url, json=payload) + + return response - def get_nodes(self,pipeline): + def __get_nodes(self,pipeline): response=requests.get(self.url+"/api/v1/nodes") print(response,response.content) result=response.json()["results"] return(result) - - def analyze_data(self,filename): + def __analyze_data(self,filename): payload={"filename":filename} response=requests.post(self.url+"/api/v1/analyze_data",data=json.dumps(payload)) + result=response.json() - - #print("RESPONSE",response,response.content) - - - result=response.json()#["results"] - return(result) + return result - - def clean_data(self,filename): + def __clean_data(self,filename): payload={"filename":filename} response=requests.post(self.url+"/api/v1/clean_data",data=json.dumps(payload)) result=response.json() - return(result) - - - def run_python_script(self,filename,dir_path): - #dir_path="C:\\Users\\EUROCOM\\Documents\\Git\\ForloopAI\\forloop_api" + return result + + def __run_python_script(self,filename,dir_path): payload={"filename":filename,"dir_path":dir_path} response=requests.post(self.url+"/api/v1/run_python_script",data=json.dumps(payload)) + result=response.json() - - print("RESPONSE",response,response.content) - - - result=response.json()#["results"] - return(result) + return result \ No newline at end of file