Support Workflows (#1338)

CHANGELOG.md

@@ -17,6 +17,10 @@ Changes are grouped as follows
 - `Fixed` for any bug fixes.
 - `Security` in case of vulnerabilities.
 
+## [6.28.0] - 2023-09-26
+### Added
+- Support for the WorkflowOrchestrationAPI with the implementation `client.workflows`.
+
 ## [6.27.0] - 2023-09-13
 ### Changed
 - Reduce concurrency in data modeling client to 1 

cognite/client/_api/functions.py

@@ -18,7 +18,6 @@
 from cognite.client import utils
 from cognite.client._api_client import APIClient
 from cognite.client._constants import DEFAULT_LIMIT_READ
-from cognite.client.credentials import OAuthClientCertificate
 from cognite.client.data_classes import (
     ClientCredentials,
     Function,
@@ -34,9 +33,9 @@
     TimestampRange,
 )
 from cognite.client.data_classes.functions import FunctionCallsFilter, FunctionsStatus
-from cognite.client.exceptions import CogniteAuthError
 from cognite.client.utils._auxiliary import is_unlimited
 from cognite.client.utils._identifier import Identifier, IdentifierSequence
+from cognite.client.utils._session import create_session_and_return_nonce
 
 if TYPE_CHECKING:
     from cognite.client import CogniteClient
@@ -395,7 +394,7 @@ def call(
         """
         identifier = IdentifierSequence.load(ids=id, external_ids=external_id).as_singleton()[0]
         id = _get_function_internal_id(self._cognite_client, identifier)
-        nonce = _create_session_and_return_nonce(self._cognite_client)
+        nonce = create_session_and_return_nonce(self._cognite_client, api_name="Functions API")
 
         if data is None:
             data = {}
@@ -523,18 +522,6 @@ def status(self) -> FunctionsStatus:
         return FunctionsStatus._load(res.json())
 
 
-def _create_session_and_return_nonce(
-    client: CogniteClient,
-    client_credentials: dict | ClientCredentials | None = None,
-) -> str:
-    if client_credentials is None:
-        if isinstance(client._config.credentials, OAuthClientCertificate):
-            raise CogniteAuthError("Client certificate credentials is not supported with the Functions API")
-    elif isinstance(client_credentials, dict):
-        client_credentials = ClientCredentials(client_credentials["client_id"], client_credentials["client_secret"])
-    return client.iam.sessions.create(client_credentials).nonce
-
-
 def get_handle_function_node(file_path: Path) -> ast.FunctionDef | None:
     return next(
         (
@@ -1037,7 +1024,9 @@ def create(
 
         """
         _get_function_identifier(function_id, function_external_id)
-        nonce = _create_session_and_return_nonce(self._cognite_client, client_credentials)
+        nonce = create_session_and_return_nonce(
+            self._cognite_client, api_name="Functions API", client_credentials=client_credentials
+        )
         body: dict[str, list[dict[str, str | int | None | dict]]] = {
             "items": [
                 {