source-intercom: ensure inline schemas, updated cdk, poetry (where possible) (#36644)

Co-authored-by: Serhii Lazebnyi <[email protected]>
Co-authored-by: Serhii Lazebnyi <[email protected]>

Author: bleonard

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

@@ -10,7 +10,7 @@ data:
   connectorSubtype: api
   connectorType: source
   definitionId: d8313939-3782-41b0-be29-b3ca20d8dd3a
-  dockerImageTag: 0.6.3
+  dockerImageTag: 0.6.5
   dockerRepository: airbyte/source-intercom
   documentationUrl: https://docs.airbyte.com/integrations/sources/intercom
   githubIssueLabel: source-intercom

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

@@ -3,7 +3,7 @@ requires = [ "poetry-core>=1.0.0",]
 build-backend = "poetry.core.masonry.api"
 
 [tool.poetry]
-version = "0.6.3"
+version = "0.6.5"
 name = "source-intercom"
 description = "Source implementation for Intercom Yaml."
 authors = [ "Airbyte <[email protected]>",]
@@ -17,7 +17,7 @@ include = "source_intercom"
 
 [tool.poetry.dependencies]
 python = "^3.9,<3.12"
-airbyte-cdk = ">=0.62.0"
+airbyte-cdk = "0.86.3"
 
 [tool.poetry.scripts]
 source-intercom = "source_intercom.run:run"

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

@@ -105,7 +105,7 @@ def observe(self, stream_slice: StreamSlice, record: Record) -> None:
         if self.is_greater_than_or_equal(record, self._state):
             self._cursor = record_cursor_value
 
-    def close_slice(self, stream_slice: StreamSlice) -> None:
+    def close_slice(self, stream_slice: StreamSlice, *args: Any) -> None:
         cursor_field = self.cursor_field.eval(self.config)
         self._state[cursor_field] = self._cursor
 
@@ -178,8 +178,8 @@ def observe(self, stream_slice: StreamSlice, record: Record) -> None:
         # observe the substream
         super().observe(stream_slice, record)
 
-    def close_slice(self, stream_slice: StreamSlice) -> None:
-        super().close_slice(stream_slice=stream_slice)
+    def close_slice(self, stream_slice: StreamSlice, *args: Any) -> None:
+        super().close_slice(stream_slice, *args)
 
     def stream_slices(self) -> Iterable[Mapping[str, Any]]:
         parent_state = (self._state or {}).get(self.parent_stream_name, {})