This is an automated email from the ASF dual-hosted git repository. dimuthuupe pushed a commit to branch cybershuttle-staging in repository https://gitbox.apache.org/repos/asf/airavata.git
commit a476d0fef98a266464aecdd9a9a744424a3d7396 Author: yasith <[email protected]> AuthorDate: Thu Apr 3 11:37:14 2025 -0400 fix bugs in python sdk after base image / api changes --- .../airavata-python-sdk/airavata_experiments/airavata.py | 12 ++++++------ .../airavata-python-sdk/airavata_jupyter_magic/__init__.py | 2 +- .../airavata-client-sdks/airavata-python-sdk/pyproject.toml | 2 +- 3 files changed, 8 insertions(+), 8 deletions(-) diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/airavata_experiments/airavata.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/airavata_experiments/airavata.py index c110837cf6..e352d909af 100644 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/airavata_experiments/airavata.py +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/airavata_experiments/airavata.py @@ -366,7 +366,7 @@ class AiravataOperator: while True: res = requests.get(f"{self.connection_svc_url()}/agent/execute/shell/{exc_id}") data = res.json() - if data["available"]: + if data["executed"]: return [fp] time.sleep(1) @@ -407,7 +407,7 @@ class AiravataOperator: while True: res = requests.get(f"{self.connection_svc_url()}/agent/execute/shell/{exc_id}") data = res.json() - if data["available"]: + if data["executed"]: files = data["responseString"].split("\n") return files time.sleep(1) @@ -447,7 +447,7 @@ class AiravataOperator: while True: res = requests.get(f"{self.connection_svc_url()}/agent/execute/shell/{exc_id}") data = res.json() - if data["available"]: + if data["executed"]: content = data["responseString"] import base64 content = base64.b64decode(content) @@ -493,7 +493,7 @@ class AiravataOperator: while True: res = requests.get(f"{self.connection_svc_url()}/agent/execute/shell/{exc_id}") data = res.json() - if data["available"]: + if data["executed"]: content = data["responseString"] import base64 content = base64.b64decode(content) @@ -762,7 +762,7 @@ class AiravataOperator: while True: # poll for response res = requests.get(f"{self.connection_svc_url()}/agent/setup/env/{exc_id}") data = res.json() - if data["available"]: + if data["setup"]: response = str(data["responseString"]) break time.sleep(1) @@ -780,7 +780,7 @@ class AiravataOperator: while True: # poll for response res = requests.get(f"{self.connection_svc_url()}/agent/execute/python/{exc_id}") data = res.json() - if data["available"]: + if data["executed"]: response = str(data["responseString"]) break time.sleep(1) diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/airavata_jupyter_magic/__init__.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/airavata_jupyter_magic/__init__.py index 90cdb8b8ee..b59cc12f0b 100644 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/airavata_jupyter_magic/__init__.py +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/airavata_jupyter_magic/__init__.py @@ -412,7 +412,7 @@ def run_on_runtime(rt_name: str, cell: str, store_history=False, silent=False, s url = api_base_url + "/api/v1/agent/execute/jupyter/" + execution_id response = requests.get(url, headers={'Accept': 'application/json'}) json_response = response.json() - if json_response.get('available'): + if json_response.get('executed'): break time.sleep(1) diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/pyproject.toml b/airavata-api/airavata-client-sdks/airavata-python-sdk/pyproject.toml index a3c780bbce..85faae97c5 100644 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/pyproject.toml +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/pyproject.toml @@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta" [project] name = "airavata-python-sdk" -version = "2.0.5" +version = "2.0.5.post1" description = "Apache Airavata Python SDK" readme = "README.md" license = "Apache-2.0"
