✨Source Monday: Bumped CDK version dependency (#36746)

Author: lazebnyi

airbyte-integrations/connectors/source-monday/metadata.yaml

@@ -10,7 +10,7 @@ data:
   connectorSubtype: api
   connectorType: source
   definitionId: 80a54ea2-9959-4040-aac1-eee42423ec9b
-  dockerImageTag: 2.0.4
+  dockerImageTag: 2.1.0
   releases:
     breakingChanges:
       2.0.0:

airbyte-integrations/connectors/source-monday/poetry.lock

@@ -3,7 +3,7 @@ requires = [ "poetry-core>=1.0.0",]
 build-backend = "poetry.core.masonry.api"
 
 [tool.poetry]
-version = "2.0.4"
+version = "2.1.0"
 name = "source-monday"
 description = "Source implementation for Monday."
 authors = [ "Airbyte <[email protected]>",]
@@ -17,7 +17,7 @@ include = "source_monday"
 
 [tool.poetry.dependencies]
 python = "^3.9,<3.12"
-airbyte-cdk = "==0.62.0"
+airbyte-cdk = "^0"
 
 [tool.poetry.scripts]
 source-monday = "source_monday.run:run"

airbyte-integrations/connectors/source-monday/pyproject.toml

@@ -82,7 +82,7 @@ def close_slice(self, stream_slice: StreamSlice, most_recent_record: Optional[Re
         self._state[self.cursor_field.eval(self.config)] = latest_record[self.cursor_field.eval(self.config)]
 
     def stream_slices(self) -> Iterable[Mapping[str, Any]]:
-        yield {}
+        yield StreamSlice(partition={}, cursor_slice={})
 
     def should_be_synced(self, record: Record) -> bool:
         """
@@ -170,7 +170,7 @@ def read_parent_stream(
         # check if state is empty ->
         if not stream_state.get(self.parent_cursor_field):
             # yield empty slice for complete fetch of items stream
-            yield {}
+            yield StreamSlice(partition={}, cursor_slice={})
             return
 
         all_ids = set()
@@ -200,11 +200,11 @@ def read_parent_stream(
 
                         # yield slice with desired number of ids
                         if self.nested_items_per_page == len(slice_ids):
-                            yield {self.substream_slice_field: slice_ids}
+                            yield StreamSlice(partition={self.substream_slice_field: slice_ids}, cursor_slice={})
                             slice_ids = list()
         # yield leftover ids if any left
         if slice_ids:
-            yield {self.substream_slice_field: slice_ids}
+            yield StreamSlice(partition={self.substream_slice_field: slice_ids}, cursor_slice={})
 
         # If the parent slice contains no records
         if empty_parent_slice:

airbyte-integrations/connectors/source-monday/source_monday/components.py

@@ -87,7 +87,7 @@ def test_given_retryable_error_when_read_teams_then_stop_syncing(self, http_mock
             for error in get_log_messages_by_log_level(output.logs, LogLevel.INFO)
             if f'Response Code: 200, Response Text: {json.dumps({"error_code": "ComplexityException", "status_code": 200})}' in error
         ]
-        assert len(error_logs) == 5
+        assert len(error_logs) == 6
 
     @HttpMocker()
     def test_given_retryable_500_error_when_read_teams_then_stop_syncing(self, http_mocker):
@@ -110,7 +110,7 @@ def test_given_retryable_500_error_when_read_teams_then_stop_syncing(self, http_
             for error in get_log_messages_by_log_level(output.logs, LogLevel.INFO)
             if f'Response Code: 500, Response Text: {json.dumps({"error_message": "Internal server error", "status_code": 500})}' in error
         ]
-        assert len(error_logs) == 5
+        assert len(error_logs) == 6
 
     @HttpMocker()
     def test_given_403_error_when_read_teams_then_ignore_the_stream(self, http_mocker):

airbyte-integrations/connectors/source-monday/unit_tests/integrations/test_teams_stream.py

@@ -33,6 +33,7 @@
 )
 def test_item_pagination_strategy(response_json, last_records, expected):
     strategy = ItemPaginationStrategy(
+        config={},
         page_size=1,
         parameters={"items_per_page": 1},
     )
@@ -73,6 +74,7 @@ def test_item_pagination_strategy(response_json, last_records, expected):
 )
 def test_item_cursor_pagination_strategy(response_json, last_records, expected):
     strategy = ItemCursorPaginationStrategy(
+        config={},
         page_size=1,
         parameters={"items_per_page": 1},
     )