From 45c16e9ff8699d9798546ff47699b9e1d87e8c4b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Daniel=20Chm=C3=BArny?= Date: Sat, 25 Nov 2023 22:13:19 +0100 Subject: [PATCH 1/2] Clear code and disable methods leading to non-existent endpoints --- forloop/forloop_core.py | 34 ++++++++++------------------------ 1 file changed, 10 insertions(+), 24 deletions(-) diff --git a/forloop/forloop_core.py b/forloop/forloop_core.py index 8102548..ebb3036 100644 --- a/forloop/forloop_core.py +++ b/forloop/forloop_core.py @@ -1,13 +1,11 @@ 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 @@ -15,45 +13,33 @@ def __init__(self, key=None, secret=None, url=None): self.url = "https://www.forloop.ai" - 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 From 8dd53a564e1710ff280835de4ecfc064cd6d66fb Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Daniel=20Chm=C3=BArny?= Date: Sat, 25 Nov 2023 22:13:52 +0100 Subject: [PATCH 2/2] Implement execute_pipeline method --- forloop/forloop_core.py | 13 ++++++++++++- 1 file changed, 12 insertions(+), 1 deletion(-) diff --git a/forloop/forloop_core.py b/forloop/forloop_core.py index ebb3036..0918d0f 100644 --- a/forloop/forloop_core.py +++ b/forloop/forloop_core.py @@ -11,7 +11,18 @@ def __init__(self, key=None, secret=None, url=None): 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): response=requests.get(self.url+"/api/v1/nodes")