Merge branch 'release/14.7'

Author: kevanescence

HISTORY.txt

@@ -2,6 +2,31 @@ Changelog
 ==========
 
 
+14.7.2 (2026-07-13)
+-------------------
+
+* Initial release for DSS 14.7.2
+
+14.7.1 (2026-07-13)
+-------------------
+
+* Initial release for DSS 14.7.1
+
+14.7.0 (2026-06-18)
+-------------------
+
+* Initial release for DSS 14.7.0
+
+14.6.2 (2026-06-15)
+-------------------
+
+* Initial release for DSS 14.6.2
+
+14.6.1 (2026-06-05)
+-------------------
+
+* Initial release for DSS 14.6.1
+
 14.6.0 (2026-05-27)
 -------------------
 

dataikuapi/dss/admin.py

@@ -27,7 +27,7 @@ def to_connection(self):
 
         :rtype: :class:`DSSConnection`
         """
-        return DSSConnection(self.client, self["name"])
+        return DSSConnection(self.client, self.name)
 
     @property
     def name(self):
@@ -36,6 +36,8 @@ def name(self):
 
         :rtype: string
         """
+        if "name" in self:
+            return self["name"]
         return self["id"]
 
     @property
@@ -46,6 +48,8 @@ def type(self):
         :return: a DSS connection type, like PostgreSQL, EC2, Azure, ...
         :rtype: string
         """
+        if "type" in self:
+            return self["type"]
         return self["label"]
 
 class DSSConnectionInfo(dict):
@@ -702,6 +706,11 @@ def get_client_as(self):
                                          extra_headers={"X-DKU-ProxyUser":  self.login}, client_certificate=self.client._session.cert)
             client_as._session.verify = self.client._session.verify
             return client_as
+        elif self.client.jwt_bearer_token is not None:
+            client_as = DSSClient(self.client.host, jwt_bearer_token = self.client.jwt_bearer_token,
+                                         extra_headers={"X-DKU-ProxyUser":  self.login}, client_certificate=self.client._session.cert)
+            client_as._session.verify = self.client._session.verify
+            return client_as
         else:
             raise ValueError("Don't know how to proxy this client")
 

dataikuapi/dss/agent.py

@@ -354,6 +354,51 @@ def wake_up(self, version_id=None):
                 "versionId": version_id
             })
 
+    def get_metrics_series(self, from_timestamp_ms=None, to_timestamp_ms=None, aggregation="MINUTE", timezone=None):
+        """
+        Get the operational metrics series for this agent.
+
+        The returned payload may include the ongoing interval for the requested granularity.
+        As a consequence, the latest datapoint is temporarily inconsistent and may evolve
+        as more raw events are flushed and aggregated at read time.
+        The requested time window is aligned to the bucket boundaries of the selected
+        aggregation before being read.
+
+        :param int from_timestamp_ms: Beginning of the requested window, inclusive, as an
+            epoch timestamp in milliseconds. The effective lower bound is rounded down
+            to the start of its bucket. Optional, defaults to the oldest retained
+            timestamp available for the requested aggregation.
+        :param int to_timestamp_ms: End of the requested window, exclusive, as an epoch
+            timestamp in milliseconds. The effective upper bound is rounded up to the
+            next bucket boundary when it falls inside a bucket.
+            Optional, defaults to the current time when omitted.
+        :param str aggregation: Aggregation granularity. Supported values are ``MINUTE``,
+            ``FIVE_MINUTES``, ``HOUR``, ``DAY`` and ``MONTH``.
+        :param str timezone: Timezone used to align bucket boundaries. Optional,
+            defaults to ``UTC``. Can be a timezone name like ``Europe/Paris``.
+        :return: The list of datapoints. Each datapoint contains a ``timestampMs``
+                 expressed as the start timestamp of its bucket in epoch
+                 milliseconds. For example, with ``HOUR`` aggregation, a datapoint
+                 at ``18:00`` represents the interval ``[18:00, 19:00)``.
+        :rtype: list[dict]
+        """
+        if from_timestamp_ms is not None and not isinstance(from_timestamp_ms, int):
+            raise TypeError("Expected int for from_timestamp_ms, got %s" % type(from_timestamp_ms).__name__)
+        if to_timestamp_ms is not None and not isinstance(to_timestamp_ms, int):
+            raise TypeError("Expected int for to_timestamp_ms, got %s" % type(to_timestamp_ms).__name__)
+        if timezone is not None and not isinstance(timezone, str):
+            raise TypeError("Expected str for timezone, got %s" % type(timezone).__name__)
+
+        return self.client._perform_json(
+            "GET", "/projects/%s/agents/%s/operational-metrics/series" % (self.project_key, self.id),
+            params={
+                "fromTimestampMs": from_timestamp_ms,
+                "toTimestampMs": to_timestamp_ms,
+                "aggregation": aggregation,
+                "timezone": timezone
+            }
+        )
+
 
 class DSSAgentSettings(DSSTaggableObjectSettings):
     """