Source Intercom: Fix incremental sync state issues

airbyte-integrations/connectors/source-intercom/acceptance-test-config.yml

@@ -20,9 +20,7 @@ acceptance_tests:
       - config_path: "secrets/config.json"
         expect_records:
           path: "integration_tests/expected_records.jsonl"
-        empty_streams:
-          - name: conversation_parts
-            bypass_reason: Deeply nested response which could not be seeded with sandbox
+        empty_streams: []
   incremental:
     tests:
       - config_path: "secrets/config.json"

airbyte-integrations/connectors/source-intercom/integration_tests/abnormal_state.json

@@ -28,7 +28,10 @@
         "name": "company_segments"
       },
       "stream_state": {
-        "updated_at": 7626086649
+        "updated_at": 7626086649,
+        "companies": {
+          "updated_at": 1676517777
+        }
       }
     }
   },
@@ -50,7 +53,10 @@
         "name": "conversation_parts"
       },
       "stream_state": {
-        "updated_at": 7626086649
+        "updated_at": 7626086649,
+        "conversations": {
+          "updated_at": 1676462031
+        }
       }
     }
   },

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

@@ -651,29 +651,18 @@ definitions:
               {{ record['updated_at'] >= stream_state.get('prior_state',
               {}).get('updated_at', 0) - (config.get('lookback_window', 0) *
               86400)}}
-        partition_router:
-          type: SubstreamPartitionRouter
-          parent_stream_configs:
-            - type: ParentStreamConfig
-              parent_key: id
-              partition_field: id
-              stream:
-                $ref: "#/definitions/streams/conversations"
       incremental_sync:
-        type: DatetimeBasedCursor
+        type: CustomIncrementalSync
+        class_name: >-
+          source_declarative_manifest.components.IncrementalSubstreamSlicerCursor
         cursor_field: updated_at
-        cursor_datetime_formats:
-          - "%s"
-          - "%ms"
-        datetime_format: "%s"
-        start_datetime:
-          type: MinMaxDatetime
-          datetime: "{{ config[\"start_date\"] }}"
-          datetime_format: "%Y-%m-%dT%H:%M:%SZ"
-        end_datetime:
-          type: MinMaxDatetime
-          datetime: "{{ now_utc().strftime('%Y-%m-%dT%H:%M:%SZ') }}"
-          datetime_format: "%Y-%m-%dT%H:%M:%SZ"
+        parent_complete_fetch: true
+        parent_stream_configs:
+          - type: ParentStreamConfig
+            stream:
+              $ref: "#/definitions/streams/conversations"
+            parent_key: id
+            partition_field: id
       transformations:
         - type: AddFields
           fields:
@@ -722,29 +711,18 @@ definitions:
               {{ record['updated_at'] >= stream_state.get('prior_state',
               {}).get('updated_at', 0) - (config.get('lookback_window', 0) *
               86400)}}
-        partition_router:
-          type: SubstreamPartitionRouter
-          parent_stream_configs:
-            - type: ParentStreamConfig
-              parent_key: id
-              partition_field: id
-              stream:
-                $ref: "#/definitions/streams/companies"
       incremental_sync:
-        type: DatetimeBasedCursor
+        type: CustomIncrementalSync
+        class_name: >-
+          source_declarative_manifest.components.IncrementalSubstreamSlicerCursor
         cursor_field: updated_at
-        cursor_datetime_formats:
-          - "%s"
-          - "%ms"
-        datetime_format: "%s"
-        start_datetime:
-          type: MinMaxDatetime
-          datetime: "{{ config[\"start_date\"] }}"
-          datetime_format: "%Y-%m-%dT%H:%M:%SZ"
-        end_datetime:
-          type: MinMaxDatetime
-          datetime: "{{ now_utc().strftime('%Y-%m-%dT%H:%M:%SZ') }}"
-          datetime_format: "%Y-%m-%dT%H:%M:%SZ"
+        parent_complete_fetch: true
+        parent_stream_configs:
+          - type: ParentStreamConfig
+            stream:
+              $ref: "#/definitions/streams/companies"
+            parent_key: id
+            partition_field: id
       schema_loader:
         type: InlineSchemaLoader
         schema:
@@ -875,8 +853,11 @@ metadata:
       conversations:
         - errorHandler
         - incrementalSync
+      conversation_parts:
+        - incrementalSync
       company_segments:
         - errorHandler
+        - incrementalSync
   testedStreams:
     activity_logs:
       hasRecords: true

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

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

docs/integrations/sources/intercom.md

@@ -96,6 +96,7 @@ The Intercom connector should not run into Intercom API limitations under normal
 
 | Version | Date       | Pull Request                                             | Subject                                                                                                                          |
 |:--------|:-----------|:---------------------------------------------------------|:---------------------------------------------------------------------------------------------------------------------------------|
+| 0.10.0 | 2024-12-19 | [49936](https://github.com/airbytehq/airbyte/pull/49936) | Migrate to manifest-only format |
 | 0.9.0-rc.1 | 2024-12-17 | [47240](https://github.com/airbytehq/airbyte/pull/47240) | Migrate to manifest-only format |
 | 0.8.3 | 2024-12-12 | [48979](https://github.com/airbytehq/airbyte/pull/48979) | Update dependencies |
 | 0.8.2 | 2024-10-29 | [47919](https://github.com/airbytehq/airbyte/pull/47919) | Update dependencies |