Skip to content

Commit

Permalink
Black format files
Browse files Browse the repository at this point in the history
  • Loading branch information
yashdattsawant committed Dec 13, 2024
1 parent c18e4c9 commit dd2b6a6
Show file tree
Hide file tree
Showing 3 changed files with 24 additions and 22 deletions.
16 changes: 10 additions & 6 deletions smsdk/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -897,13 +897,15 @@ def create_widget_share_link(self, context="/analysis/datavis", **kwargs):
base_url = get_url(
self.config["protocol"], self.tenant, self.config["site.domain"]
)
return dataViz(self.session, base_url).create_widget_share_link(context,**kwargs)
return dataViz(self.session, base_url).create_widget_share_link(
context, **kwargs
)

@version_check_decorator
def fetch_list_of_udf(self):
base_url = get_url(
self.config["protocol"], self.tenant, self.config["site.domain"]
)
self.config["protocol"], self.tenant, self.config["site.domain"]
)
# load the entity class and initialize it
cls = smsdkentities.get("dev_udf")(self.session, base_url)
udf_list = getattr(cls, "get_list_of_udf")()
Expand All @@ -919,9 +921,11 @@ def get_udf_data(self, udf_name, **params):
)
# load the entity class and initialize it
cls = smsdkentities.get("dev_udf")(self.session, base_url)
udf_data = getattr(cls, "get_udf_data")(udf_name,params)
udf_data = getattr(cls, "get_udf_data")(udf_name, params)
return udf_data
else:
log.error(f'UDF named "{udf_name}" does not exist. Please check the name again')
log.error(
f'UDF named "{udf_name}" does not exist. Please check the name again'
)
else:
log.error('Name of user defined function is required')
log.error("Name of user defined function is required")
10 changes: 5 additions & 5 deletions smsdk/smsdk_entities/data_viz/data_viz.py
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,7 @@ def create_share_link(
"selectedTimeZone": time_selection["time_zone"],
}
else:
dateRange={}
dateRange = {}
url_params["state"] = {
"dataModel": model,
"asset": asset,
Expand Down Expand Up @@ -157,7 +157,7 @@ def create_share_link(
url_params["state"]["yAxis"] = yAxis
response = getattr(self.session, "post")(url, json=url_params)
return "{}/#{}/s/{}".format(
self.base_url,url_params["context"], response.json()["state_hash"]
self.base_url, url_params["context"], response.json()["state_hash"]
)

@mod_util
Expand Down Expand Up @@ -185,7 +185,7 @@ def get_dashboard_widget_data(self, model, *args, **kwargs):
return records

@mod_util
def create_widget_share_link(self,context,**kwargs):
def create_widget_share_link(self, context, **kwargs):
url = "{}{}".format(self.base_url, ENDPOINTS["DataViz"]["share_link"])
url_params = {}
url_params["state_hash"] = str(uuid.uuid4())[:8]
Expand All @@ -194,8 +194,8 @@ def create_widget_share_link(self,context,**kwargs):
url_params["in_use_workspace"] = self.session.headers["X-Sm-Workspace-Id"]
except:
pass
url_params["state"]=kwargs
url_params["state"] = kwargs
response = getattr(self.session, "post")(url, json=url_params)
return "{}/#{}/s/{}".format(
self.base_url, url_params["context"], response.json()["state_hash"]
)
)
20 changes: 9 additions & 11 deletions smsdk/smsdk_entities/dev_udf/dev_udf.py
Original file line number Diff line number Diff line change
Expand Up @@ -42,10 +42,10 @@ def get_list_of_udf(self):
"""
url = "{}{}".format(self.base_url, ENDPOINTS["UDF_dev"]["list_url"])
html_content = self.session.get(url).text
soup = BeautifulSoup(html_content, 'html.parser')
table = soup.find('table')
rows = table.find('tbody').find_all('tr')
list_of_udfs = [row.find_all('td')[0].text for row in rows]
soup = BeautifulSoup(html_content, "html.parser")
table = soup.find("table")
rows = table.find("tbody").find_all("tr")
list_of_udfs = [row.find_all("td")[0].text for row in rows]
return list_of_udfs

@mod_util
Expand All @@ -54,15 +54,13 @@ def get_udf_data(self, udf_name, params):
Utility function to get the data after executing udf notebook
"""
url = "{}{}".format(self.base_url, ENDPOINTS["UDF_dev"]["url"])
payload = {
"name": udf_name
}
payload = {"name": udf_name}
if params:
payload['parameters']= params
payload["parameters"] = params
results = self.session.post(url, json=payload)
time.sleep(10)
async_task_id = results.json().get('response').get('task_id')
results = self.session.get(url+'/'+async_task_id).json()
async_task_id = results.json().get("response").get("task_id")
results = self.session.get(url + "/" + async_task_id).json()
time.sleep(10)
data = results.get('response').get('meta')[0].get('data')
data = results.get("response").get("meta")[0].get("data")
return data

0 comments on commit dd2b6a6

Please sign in to comment.