[CDF-22379] Hosted Extractors Source: Kafka and Rest (#1899)

CHANGELOG.md

@@ -17,7 +17,11 @@ Changes are grouped as follows
 - `Fixed` for any bug fixes.
 - `Security` in case of vulnerabilities.
 
-## [7.62.2] - 2024-09-23
+## [7.62.3] - 2024-09-24
+### Added
+- [Feature Preview - alpha] Support for `Kafka` and `Rest` sources in `client.hosted_extractors.sources`.
+
+## [7.62.2] - 2024-09-24
 ### Added
 - [Feature Preview - alpha] Support for `client.hosted_extractors.mappings`.
 

cognite/client/_version.py

@@ -1,4 +1,4 @@
 from __future__ import annotations
 
-__version__ = "7.62.2"
+__version__ = "7.62.3"
 __api_subversion__ = "20230101"

cognite/client/data_classes/_base.py

@@ -533,7 +533,7 @@ def __init__(self, update_object: T_CogniteUpdate, name: str) -> None:
         self._update_object = update_object
         self._name = name
 
-    def _set(self, value: None | str | int | bool | dict) -> T_CogniteUpdate:
+    def _set(self, value: None | str | int | bool | dict | list) -> T_CogniteUpdate:
         if value is None:
             self._update_object._set_null(self._name)
         else:

cognite/client/data_classes/hosted_extractors/__init__.py

@@ -53,12 +53,18 @@
     EventHubSource,
     EventHubSourceUpdate,
     EventHubSourceWrite,
+    KafkaSource,
+    KafkaSourceUpdate,
+    KafkaSourceWrite,
     MQTT3Source,
     MQTT3SourceUpdate,
     MQTT3SourceWrite,
     MQTT5Source,
     MQTT5SourceUpdate,
     MQTT5SourceWrite,
+    RestSource,
+    RestSourceUpdate,
+    RestSourceWrite,
     Source,
     SourceList,
     SourceUpdate,
@@ -124,4 +130,10 @@
     "ProtoBufInput",
     "JSONInput",
     "XMLInput",
+    "RestSource",
+    "RestSourceWrite",
+    "RestSourceUpdate",
+    "KafkaSource",
+    "KafkaSourceWrite",
+    "KafkaSourceUpdate",
 ]