Merge branch 'master' into fix-propagate-is-false

haakonvt · web-flow · commit ed79611b79fe · 2026-01-07T21:55:03.000+01:00
diff --git a/.github/actions/setup/action.yml b/.github/actions/setup/action.yml
@@ -13,7 +13,7 @@ inputs:
 runs:
   using: 'composite'
   steps:
-    - uses: actions/setup-python@e797f83bcb11b83ae66e0230d6156d7c80228e7c # v6
+    - uses: actions/setup-python@83679a892e2d95755f2dac6acb0bfd1e9ac5d548 # v6
       with:
         python-version: ${{ inputs.python_version }}
         cache: 'pip'
diff --git a/.github/workflows/build.yml b/.github/workflows/build.yml
@@ -14,7 +14,7 @@ jobs:
   lint:
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683 # v4
+      - uses: actions/checkout@8e8c483db84b4bee98b60c0593521ed34d9990e8 # v6
       - uses: ./.github/actions/setup
         with:
           extras: "-E pandas"
@@ -24,23 +24,23 @@ jobs:
   build_docs:
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683 # v4
+      - uses: actions/checkout@8e8c483db84b4bee98b60c0593521ed34d9990e8 # v6
       - uses: ./.github/actions/setup
       - name: Build docs
         run: cd docs && make html SPHINXOPTS="-W --keep-going"
 
   build_package:
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683 # v4
+      - uses: actions/checkout@8e8c483db84b4bee98b60c0593521ed34d9990e8 # v6
       - uses: ./.github/actions/setup
       - name: Build package
         run: poetry build
 
   test_core:
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683 # v4
+      - uses: actions/checkout@8e8c483db84b4bee98b60c0593521ed34d9990e8 # v6
       - uses: ./.github/actions/setup
       - name: Test core
         run: pytest tests/tests_unit -n8 --dist loadscope --maxfail 10 -m 'not dsl' --test-deps-only-core
@@ -53,7 +53,7 @@ jobs:
         os: [ubuntu-latest, windows-latest]
         python-version: ["3.10", "3.11", "3.12", "3.13"]
     steps:
-      - uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683 # v4
+      - uses: actions/checkout@8e8c483db84b4bee98b60c0593521ed34d9990e8 # v6
       - uses: ./.github/actions/setup
         with:
           python_version: ${{ matrix.python-version }}
diff --git a/.github/workflows/cdf_auth.yaml b/.github/workflows/cdf_auth.yaml
@@ -24,7 +24,7 @@ jobs:
         PROVIDER: "entra_id"
         LOGIN_FLOW: "client_credentials"
     steps:
-      - uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683 # v4
+      - uses: actions/checkout@8e8c483db84b4bee98b60c0593521ed34d9990e8 # v6
       - name: Build the CDF Groups
         working-directory: scripts/toolkit
         run: cdf build --env ${{ matrix.cdf_project }}
diff --git a/.github/workflows/manual-pre-release.yaml b/.github/workflows/manual-pre-release.yaml
@@ -10,7 +10,7 @@ jobs:
     runs-on: windows-latest
     environment: CD
     steps:
-      - uses: actions/checkout@v4
+      - uses: actions/checkout@8e8c483db84b4bee98b60c0593521ed34d9990e8 # v6
 
       - uses: ./.github/actions/setup
 
diff --git a/.github/workflows/release.yaml b/.github/workflows/release.yaml
@@ -10,7 +10,7 @@ jobs:
     runs-on: windows-latest
     environment: CD
     steps:
-      - uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683 # v4
+      - uses: actions/checkout@8e8c483db84b4bee98b60c0593521ed34d9990e8 # v6
       - uses: ./.github/actions/setup
         with:
           extras: '-E all'
diff --git a/.github/workflows/verify-jupyter.yml b/.github/workflows/verify-jupyter.yml
@@ -9,7 +9,7 @@ jobs:
   build_and_test_jupyter_pyodide:
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683 # v4
+      - uses: actions/checkout@8e8c483db84b4bee98b60c0593521ed34d9990e8 # v6
       - uses: actions/setup-python@e797f83bcb11b83ae66e0230d6156d7c80228e7c # v6
         with:
           python-version: '3.10'
diff --git a/.github/workflows/verify-streamlit.yml b/.github/workflows/verify-streamlit.yml
@@ -9,7 +9,7 @@ jobs:
   build_and_test_streamlit_pyodide:
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683 # v4
+      - uses: actions/checkout@8e8c483db84b4bee98b60c0593521ed34d9990e8 # v6
       - uses: actions/setup-python@e797f83bcb11b83ae66e0230d6156d7c80228e7c # v6
         with:
           python-version: '3.10'
diff --git a/.release-please-manifest.json b/.release-please-manifest.json
@@ -1,3 +1,3 @@
 {
-  ".": "7.90.1"
+  ".": "7.91.0"
 }
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -13,6 +13,19 @@ As of 2025-08-29, changes are grouped as follows
 - 🐛 Bug Fixes: Bug fixes.
 - ⚡ Improvements: Transparent changes, e.g. better performance.
 
+## [7.91.0](https://github.com/cognitedata/cognite-sdk-python/compare/cognite-sdk-python-v7.90.1...cognite-sdk-python-v7.91.0) (2026-01-06)
+
+
+### Features
+
+* **simint:** make `simulator_integration_external_id` optional on runs, routines and routine revisions ([#2420](https://github.com/cognitedata/cognite-sdk-python/issues/2420)) ([a18702b](https://github.com/cognitedata/cognite-sdk-python/commit/a18702b10e940bec9684589c86bd375a23613258))
+* **workflow-triggers:** add pause and resume functionality ([#2413](https://github.com/cognitedata/cognite-sdk-python/issues/2413)) ([1afc695](https://github.com/cognitedata/cognite-sdk-python/commit/1afc6951e26c9b1c59a63aca5a0b69fd19d6473e))
+
+
+### Bug Fixes
+
+* add warning when operator is not passed to instances/search ([#2390](https://github.com/cognitedata/cognite-sdk-python/issues/2390)) ([8f8af02](https://github.com/cognitedata/cognite-sdk-python/commit/8f8af0283f61015f40723e91a1a7bc13b58e861a))
+
 ## [7.90.1](https://github.com/cognitedata/cognite-sdk-python/compare/cognite-sdk-python-v7.90.0...cognite-sdk-python-v7.90.1) (2025-11-27)
 
 
diff --git a/cognite/client/_api/data_modeling/instances.py b/cognite/client/_api/data_modeling/instances.py
@@ -5,6 +5,7 @@
 import logging
 import random
 import time
+import warnings
 from collections.abc import Callable, Iterable, Iterator, Sequence
 from datetime import datetime, timezone
 from threading import Thread
@@ -1084,7 +1085,7 @@ def search(
         include_typing: bool = False,
         limit: int | None = DEFAULT_LIMIT_READ,
         sort: Sequence[InstanceSort | dict] | InstanceSort | dict | None = None,
-        operator: Literal["AND", "OR"] = "OR",
+        operator: Literal["AND", "OR"] | None = None,
     ) -> NodeList[Node]: ...
 
     @overload
@@ -1101,7 +1102,7 @@ def search(
         include_typing: bool = False,
         limit: int | None = DEFAULT_LIMIT_READ,
         sort: Sequence[InstanceSort | dict] | InstanceSort | dict | None = None,
-        operator: Literal["AND", "OR"] = "OR",
+        operator: Literal["AND", "OR"] | None = None,
     ) -> EdgeList[Edge]: ...
 
     @overload
@@ -1118,7 +1119,7 @@ def search(
         include_typing: bool = False,
         limit: int | None = DEFAULT_LIMIT_READ,
         sort: Sequence[InstanceSort | dict] | InstanceSort | dict | None = None,
-        operator: Literal["AND", "OR"] = "OR",
+        operator: Literal["AND", "OR"] | None = None,
     ) -> NodeList[T_Node]: ...
 
     @overload
@@ -1135,7 +1136,7 @@ def search(
         include_typing: bool = False,
         limit: int | None = DEFAULT_LIMIT_READ,
         sort: Sequence[InstanceSort | dict] | InstanceSort | dict | None = None,
-        operator: Literal["AND", "OR"] = "OR",
+        operator: Literal["AND", "OR"] | None = None,
     ) -> EdgeList[T_Edge]: ...
 
     def search(
@@ -1150,7 +1151,7 @@ def search(
         include_typing: bool = False,
         limit: int | None = DEFAULT_LIMIT_READ,
         sort: Sequence[InstanceSort | dict] | InstanceSort | dict | None = None,
-        operator: Literal["AND", "OR"] = "OR",
+        operator: Literal["AND", "OR"] | None = None,
     ) -> NodeList[T_Node] | EdgeList[T_Edge]:
         """`Search instances <https://developer.cognite.com/api/v1/#tag/Instances/operation/searchInstances>`_
 
@@ -1166,34 +1167,43 @@ def search(
             limit (int | None): Maximum number of instances to return. Defaults to 25. Will return the maximum number
                 of results (1000) if set to None, -1, or math.inf.
             sort (Sequence[InstanceSort | dict] | InstanceSort | dict | None): How you want the listed instances information ordered.
-            operator (Literal['AND', 'OR']): Controls how multiple search terms are combined when matching documents. OR (default): A document matches if it contains any of the query terms in the searchable fields. This typically returns more results but with lower precision. AND: A document matches only if it contains all of the query terms across the searchable fields. This typically returns fewer results but with higher relevance.
+            operator (Literal['AND', 'OR'] | None): Controls how multiple search terms are combined when matching documents.
+                AND: A document matches only if it contains all of the query terms across the searchable fields. This typically
+                returns fewer results but with higher relevance. OR: A document matches if it contains any of the query terms in the searchable fields.
+                This typically returns more results but with lower precision. Note: If not specified, will default to the API default, which will change from
+                'OR' to 'AND' sometime in Q1 2027.
 
         Returns:
             NodeList[T_Node] | EdgeList[T_Edge]: Search result with matching nodes or edges.
 
         Examples:
 
-            Search for Arnold in the person view in the name property:
+            Search for equipment containing both 'centrifugal' and 'pump' in the description:
 
                 >>> from cognite.client import CogniteClient
                 >>> from cognite.client.data_classes.data_modeling import ViewId
                 >>> client = CogniteClient()
+                >>> view = ViewId("assetSpace", "EquipmentView", "v1")
                 >>> res = client.data_modeling.instances.search(
-                ...     ViewId("mySpace", "PersonView", "v1"),
-                ...     query="Arnold",
-                ...     properties=["name"],
+                ...     view,
+                ...     query="centrifugal pump",
+                ...     properties=["description"],
+                ...     operator="AND"
                 ... )
 
-            Search for Tarantino, Ritchie or Scorsese in the person view in the name property, but only born after 1942:
+            Search for 'pump', 'valve' or 'compressor', but filter on those installed after 2015:
 
                 >>> from cognite.client.data_classes.data_modeling import ViewId
                 >>> from cognite.client.data_classes import filters
-                >>> born_after_1942 = filters.Range(["mySpace", "PersonView/v1", "birthYear"], gt=1942)
+                >>> installed_after_2015 = filters.Range(
+                ...     ["assetSpace", "EquipmentView/v1", "installationYear"],
+                ...     gt=2015,
+                ... )
                 >>> res = client.data_modeling.instances.search(
-                ...     ViewId("mySpace", "PersonView", "v1"),
-                ...     query="Tarantino Ritchie Scorsese",
-                ...     properties=["name"],
-                ...     filter=born_after_1942,
+                ...     view,
+                ...     query="pump valve compressor",
+                ...     properties=["name", "description"],
+                ...     filter=installed_after_2015,
                 ...     operator="OR"
                 ... )
         """
@@ -1219,10 +1229,20 @@ def search(
             "view": view.dump(camel_case=True),
             "instanceType": instance_type_str,
             "limit": self._SEARCH_LIMIT if is_unlimited(limit) else limit,
-            "operator": operator.upper(),
         }
-        if body["operator"] not in ["AND", "OR"]:
-            raise ValueError(f"Invalid {operator=}. Must be 'AND' or 'OR'.")
+        if operator is None:
+            warnings.warn(
+                "The default operator for instance search will change from 'OR' to 'AND' sometime in Q1 2027. In the "
+                "next major version release (v8), the default will be changed to 'AND', which is the recommended "
+                "setting for most use cases. Please explicitly pass the operator to avoid this warning.",
+                UserWarning,  # FutureWarning is more correct, but is ignored by default and we want users to see this
+            )
+        else:
+            op_up = operator.upper()
+            if op_up not in ("AND", "OR"):
+                raise ValueError(f"Invalid {operator=}. Must be 'AND' or 'OR'.")
+            body["operator"] = op_up
+
         if query:
             body["query"] = query
         if properties:
diff --git a/cognite/client/_api/workflows/triggers.py b/cognite/client/_api/workflows/triggers.py
@@ -217,3 +217,45 @@ def list_runs(self, external_id: str, limit: int | None = DEFAULT_LIMIT_READ) ->
             list_cls=WorkflowTriggerRunList,
             limit=limit,
         )
+
+    def pause(self, external_id: str) -> None:
+        """`Pause a workflow trigger. <https://api-docs.cognite.com/20230101/tag/Workflow-triggers/operation/pauseTrigger>`_
+
+        When a trigger is paused, it will not trigger new workflow executions.
+        This operation is idempotent - pausing an already paused trigger has no effect.
+
+        Args:
+            external_id (str): The external id of the trigger to pause.
+
+        Examples:
+
+            Pause a trigger:
+
+                >>> from cognite.client import CogniteClient
+                >>> client = CogniteClient()
+                >>> client.workflows.triggers.pause("my_trigger")
+        """
+        self._post(
+            url_path=interpolate_and_url_encode(self._RESOURCE_PATH + "/{}/pause", external_id),
+        )
+
+    def resume(self, external_id: str) -> None:
+        """`Resume a paused workflow trigger. <https://api-docs.cognite.com/20230101/tag/Workflow-triggers/operation/resumeTrigger>`_
+
+        When a trigger is resumed, it will start triggering workflow executions again according to its trigger rule.
+        This operation is idempotent - resuming an already active trigger has no effect.
+
+        Args:
+            external_id (str): The external id of the trigger to resume.
+
+        Examples:
+
+            Resume a trigger:
+
+                >>> from cognite.client import CogniteClient
+                >>> client = CogniteClient()
+                >>> client.workflows.triggers.resume("my_trigger")
+        """
+        self._post(
+            url_path=interpolate_and_url_encode(self._RESOURCE_PATH + "/{}/resume", external_id),
+        )
diff --git a/cognite/client/_version.py b/cognite/client/_version.py
@@ -1,5 +1,5 @@
 from __future__ import annotations
 
-__version__ = "7.90.1"  # x-release-please-version
+__version__ = "7.91.0"  # x-release-please-version
 
 __api_subversion__ = "20230101"
diff --git a/cognite/client/data_classes/workflows.py b/cognite/client/data_classes/workflows.py
@@ -1579,6 +1579,7 @@ class WorkflowTrigger(WorkflowTriggerCore):
         trigger_rule (WorkflowTriggerRule): The trigger rule of the workflow version trigger.
         workflow_external_id (str): The external ID of the workflow.
         workflow_version (str): The version of the workflow.
+        is_paused (bool): Whether the trigger is paused.
         input (dict | None): The input data passed to the workflow when an execution is started. Defaults to None.
         metadata (dict | None): Application specific metadata. Defaults to None.
         created_time (int | None): The time when the workflow version trigger was created. Unix timestamp in milliseconds. Defaults to None.
@@ -1591,6 +1592,7 @@ def __init__(
         trigger_rule: WorkflowTriggerRule,
         workflow_external_id: str,
         workflow_version: str,
+        is_paused: bool,
         input: dict | None = None,
         metadata: dict | None = None,
         created_time: int | None = None,
@@ -1606,6 +1608,7 @@ def __init__(
         )
         self.created_time = created_time
         self.last_updated_time = last_updated_time
+        self.is_paused = is_paused
 
     def dump(self, camel_case: bool = True) -> dict[str, Any]:
         item: dict[str, Any] = {
@@ -1622,6 +1625,7 @@ def dump(self, camel_case: bool = True) -> dict[str, Any]:
             item["created_time"] = self.created_time
         if self.last_updated_time:
             item["last_updated_time"] = self.last_updated_time
+        item["is_paused"] = self.is_paused
         if camel_case:
             return convert_all_keys_to_camel_case(item)
         return item
@@ -1637,6 +1641,7 @@ def _load(cls, resource: dict, cognite_client: CogniteClient | None = None) -> W
             metadata=resource.get("metadata"),
             created_time=resource.get("createdTime"),
             last_updated_time=resource.get("lastUpdatedTime"),
+            is_paused=resource["isPaused"],
         )
 
     def as_write(self) -> WorkflowTriggerUpsert:
diff --git a/docs/source/data_workflows.rst b/docs/source/data_workflows.rst
@@ -87,6 +87,14 @@ Delete Triggers
 ^^^^^^^^^^^^^^^
 .. automethod:: cognite.client._api.workflows.WorkflowTriggerAPI.delete
 
+Pause Trigger
+^^^^^^^^^^^^^
+.. automethod:: cognite.client._api.workflows.WorkflowTriggerAPI.pause
+
+Resume Trigger
+^^^^^^^^^^^^^^
+.. automethod:: cognite.client._api.workflows.WorkflowTriggerAPI.resume
+
 
 Data Workflows data classes
 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
diff --git a/poetry.lock b/poetry.lock
diff --git a/pyproject.toml b/pyproject.toml
diff --git a/tests/tests_integration/test_api/test_datapoints.py b/tests/tests_integration/test_api/test_datapoints.py
diff --git a/tests/tests_integration/test_api/test_workflows.py b/tests/tests_integration/test_api/test_workflows.py

Original file line number	Diff line number	Diff line change
`@@ -1,3 +1,3 @@`
`1`	`1`	`{`
`2`		`- ".": "7.90.1"`
	`2`	`+ ".": "7.91.0"`
`3`	`3`	`}`