Merge branch 'CDF-28136-fix-workflow-integration-test-teardown' of ssh://github.com/cognitedata/cognite-sdk-python into CDF-28136-fix-workflow-integration-test-teardown

Author: vincent-cognite

.release-please-manifest.json

@@ -1,3 +1,3 @@
 {
-  ".": "8.9.0"
+  ".": "8.10.0"
 }

CHANGELOG.md

@@ -13,6 +13,24 @@ As of 2025-08-29, changes are grouped as follows
 - 🐛 Bug Fixes: Bug fixes.
 - ⚡ Improvements: Transparent changes, e.g. better performance.
 
+## [8.10.0](https://github.com/cognitedata/cognite-sdk-python/compare/cognite-sdk-python-v8.9.0...cognite-sdk-python-v8.10.0) (2026-06-22)
+
+
+### Features
+
+* **Data Modeling, Time Series:** Extend Data Modeling with Time Series /retrieve + /list (DM-3842) ([#2672](https://github.com/cognitedata/cognite-sdk-python/issues/2672)) ([d8e8d83](https://github.com/cognitedata/cognite-sdk-python/commit/d8e8d830bf52ae6c11d128ad819715c87633bebe))
+* **metering:** add Python SDK support for the Metering API ([#2663](https://github.com/cognitedata/cognite-sdk-python/issues/2663)) ([9077f00](https://github.com/cognitedata/cognite-sdk-python/commit/9077f007a1801a7eb36d312f7b50bcc276ccc704))
+* **records:** add upsert endpoint ([#2679](https://github.com/cognitedata/cognite-sdk-python/issues/2679)) ([f862306](https://github.com/cognitedata/cognite-sdk-python/commit/f862306fe62a55230a7593345955c2ba4eb94386))
+* **workflows:** add WorkflowRecordStreamTriggerRule to workflow triggers ([#2690](https://github.com/cognitedata/cognite-sdk-python/issues/2690)) ([9ecf95c](https://github.com/cognitedata/cognite-sdk-python/commit/9ecf95c7ab2c8e9a6739f2295a8a61d2f165d92f))
+
+
+### Bug Fixes
+
+* **docs:** correct typo in Postgres Gateway Users retrieve URL ([#2685](https://github.com/cognitedata/cognite-sdk-python/issues/2685)) ([89dafd1](https://github.com/cognitedata/cognite-sdk-python/commit/89dafd116a34d00aea05d10d7c7e2d41fe09acba))
+* don't inject null cursor in _list_generator_raw_responses ([#2684](https://github.com/cognitedata/cognite-sdk-python/issues/2684)) ([7934665](https://github.com/cognitedata/cognite-sdk-python/commit/793466576823bc307d209b10f91967bc19ecb902))
+* **exceptions:** Raise specific error CogniteNotFoundError also on 404 ([#2689](https://github.com/cognitedata/cognite-sdk-python/issues/2689)) ([4831bca](https://github.com/cognitedata/cognite-sdk-python/commit/4831bcad1470d270ab03c37692648be06314ee4a))
+* narrow Sequence to Iterable in transformer mixins ([#2691](https://github.com/cognitedata/cognite-sdk-python/issues/2691)) ([aa2316c](https://github.com/cognitedata/cognite-sdk-python/commit/aa2316c8578ff5fa97ca143194a42c36548c6354))
+
 ## [8.9.0](https://github.com/cognitedata/cognite-sdk-python/compare/cognite-sdk-python-v8.8.0...cognite-sdk-python-v8.9.0) (2026-06-08)
 
 

cognite/client/_api/data_modeling/records.py

@@ -2,11 +2,10 @@
 
 import asyncio
 from collections.abc import Sequence
-from typing import TYPE_CHECKING, ClassVar, Literal
+from typing import TYPE_CHECKING, Any, Literal
 
 from cognite.client._api_client import APIClient
 from cognite.client.data_classes.data_modeling.records import RecordId, RecordIdSequence, RecordWrite
-from cognite.client.utils._concurrency import RecordsConcurrencyOperation
 from cognite.client.utils._experimental import FeaturePreviewWarning
 from cognite.client.utils._url import interpolate_and_url_encode
 
@@ -22,16 +21,11 @@ def __init__(self, config: ClientConfig, api_version: str | None, cognite_client
             api_maturity="General Availability", sdk_maturity="alpha", feature_name="Records"
         )
 
-    _OPERATION_TO_RATE_LIMIT: ClassVar[dict[str, RecordsConcurrencyOperation]] = {
-        "write": RecordsConcurrencyOperation.WRITE,
-        "delete": RecordsConcurrencyOperation.WRITE,
-    }
-
-    def _get_semaphore(self, operation: Literal["write", "delete"]) -> asyncio.BoundedSemaphore:
+    def _get_semaphore(self, operation: Any) -> asyncio.BoundedSemaphore:
         from cognite.client import global_config
 
         return global_config.concurrency_settings.records._semaphore_factory(
-            self._OPERATION_TO_RATE_LIMIT[operation], project=self._cognite_client.config.project
+            operation, project=self._cognite_client.config.project
         )
 
     def _records_url(self, stream_id: str, suffix: str = "") -> str:

cognite/client/_sync_api/data_modeling/records.py

@@ -1,5 +1,5 @@
 from __future__ import annotations
 
-__version__ = "8.9.0"  # x-release-please-version
+__version__ = "8.10.0"  # x-release-please-version
 
 __api_subversion__ = "20230101"

cognite/client/_version.py

@@ -7,7 +7,6 @@
 from abc import ABC, abstractmethod
 from collections import UserList
 from collections.abc import Callable, Coroutine
-from enum import Enum
 from typing import (
     Any,
     Literal,
@@ -222,45 +221,47 @@ def __repr__(self) -> str:
         )
 
 
-class RecordsConcurrencyOperation(Enum):
-    WRITE = "write"
-
-
 class RecordsGlobalConcurrencyConfig(ConcurrencyConfig):
     """
     Global concurrency settings for the Records API. Named "global" to distinguish from
     future per-endpoint rate limits that may be added later.
 
     Args:
         concurrency_settings (ConcurrencySettings): Reference to the parent settings object.
+        read (int): Maximum concurrent read requests (list, retrieve, sync).
         write (int): Maximum concurrent write requests (ingest, delete).
     """
 
     def __init__(
         self,
         concurrency_settings: ConcurrencySettings,
+        read: int,
         write: int,
     ) -> None:
-        super().__init__(concurrency_settings, "records", read=0, write=write, delete=0)
+        super().__init__(concurrency_settings, "records", read=read, write=write, delete=0)
 
-    def _semaphore_factory(self, operation: RecordsConcurrencyOperation, project: str) -> asyncio.BoundedSemaphore:
-        key = (operation.value, project, asyncio.get_running_loop())
+    def _semaphore_factory(
+        self, operation: Literal["read", "write", "delete"], project: str
+    ) -> asyncio.BoundedSemaphore:
+        key = (operation, project, asyncio.get_running_loop())
         if key in self._semaphore_cache:
             return self._semaphore_cache[key]
 
         from cognite.client import global_config
 
         global_config.concurrency_settings._freeze()
         match operation:
-            case RecordsConcurrencyOperation.WRITE:
+            case "read":
+                sem = asyncio.BoundedSemaphore(self._read)
+            case "write" | "delete":
                 sem = asyncio.BoundedSemaphore(self._write)
             case _:
                 assert_never(operation)
         self._semaphore_cache[key] = sem
         return sem
 
     def __repr__(self) -> str:
-        return f"Concurrency[records](write={self._write})"
+        return f"Concurrency[records](read={self._read}, write={self._write})"
 
 
 class FileConcurrencyConfig(ConcurrencyConfig):
@@ -425,7 +426,7 @@ def __init__(self) -> None:
             write_schema=1,
         )
         self._files = FileConcurrencyConfig(self, read=4, write=2, upload=5, download=5, delete=2, open_files=15)
-        self._records = RecordsGlobalConcurrencyConfig(self, write=20)
+        self._records = RecordsGlobalConcurrencyConfig(self, read=4, write=20)
 
     @functools.cached_property
     def _all_concurrency_configs(self) -> list[ConcurrencyConfig]:

cognite/client/utils/_concurrency.py

@@ -1,6 +1,6 @@
 [project]
 name = "cognite-sdk"
-version = "8.9.0"
+version = "8.10.0"
 
 description = "Cognite Python SDK"
 readme = "README.md"