Adding version handler for aqua

Author: kumar-shivam-ranjan

ads/aqua/client/client.py

@@ -314,11 +314,9 @@ def _parse_streaming_line(
         try:
             json_line = json.loads(line)
             logger.debug(f"Parsed JSON line: {json_line}")
-        except json.JSONDecodeError as e:
+        except json.JSONDecodeError:
             logger.debug(f"Error decoding JSON from line: {line}")
-            raise json.JSONDecodeError(
-                f"Error decoding JSON from line: {e!s}", e.doc, e.pos
-            ) from e
+            return None
 
         if json_line.get("object") == "error":
             # Raise an error for error objects in the stream

ads/aqua/extension/common_handler.py

@@ -1,8 +1,8 @@
 #!/usr/bin/env python
 # Copyright (c) 2025 Oracle and/or its affiliates.
 # Licensed under the Universal Permissive License v 1.0 as shown at https://oss.oracle.com/licenses/upl/
-
-
+import json
+import os
 from importlib import metadata
 
 import huggingface_hub
@@ -18,6 +18,10 @@
 )
 from ads.aqua.extension.base_handler import AquaAPIhandler
 from ads.aqua.extension.errors import Errors
+from ads.common.object_storage_details import ObjectStorageDetails
+from ads.common.utils import read_file
+from ads.config import CONDA_BUCKET_NAME, CONDA_BUCKET_NS
+from ads.opctl.operator.common.utils import default_signer
 
 
 class ADSVersionHandler(AquaAPIhandler):
@@ -28,6 +32,42 @@ def get(self):
         self.finish({"data": metadata.version("oracle_ads")})
 
 
+class AquaVersionHandler(AquaAPIhandler):
+    @handle_exceptions
+    def get(self):
+        """
+        Returns the current and latest deployed version of AQUA
+
+        {
+          "installed": {
+            "aqua": "0.1.3.0",
+            "ads": "2.14.2"
+          },
+          "latest": {
+            "aqua": "0.1.4.0",
+            "ads": "2.14.4"
+          }
+        }
+
+        """
+
+        current_version_path = os.path.join(
+            os.path.dirname(os.path.abspath(__file__)), "..", "version.json"
+        )
+        latest_version_artifact_path = ObjectStorageDetails(
+            CONDA_BUCKET_NAME, CONDA_BUCKET_NS, "service_pack/aqua_latest_version.json"
+        ).path
+        latest_version_content = read_file(
+            latest_version_artifact_path, auth=default_signer()
+        )
+        current_version_content = read_file(current_version_path)
+        response = {
+            **json.loads(current_version_content),
+            **json.loads(latest_version_content),
+        }
+        return self.finish(response)
+
+
 class CompatibilityCheckHandler(AquaAPIhandler):
     """The handler to check if the extension is compatible."""
 
@@ -118,4 +158,5 @@ def get(self):
     ("network_status", NetworkStatusHandler),
     ("hf_login", HFLoginHandler),
     ("hf_logged_in", HFUserStatusHandler),
+    ("aqua_version", AquaVersionHandler),
 ]

ads/aqua/version.json

@@ -0,0 +1,6 @@
+{
+  "installed": {
+    "ads": "2.14.2",
+    "aqua": "0.1.3.0"
+  }
+}