🐛 Source-Snapchat: always set the full state object (#20498)

* always set the full state * format * format * remove debug prints * assign the full object * update * Update * auto-bump connector version Co-authored-by: Octavia Squidington III <octavia-squidington-iii@users.noreply.github.com>
airbytehq · Dec 15, 2022 · 90c17de · 90c17de
1 parent 2392acb
commit 90c17de
Show file tree

Hide file tree

Showing 5 changed files with 7 additions and 7 deletions.
diff --git a/airbyte-config/init/src/main/resources/seed/source_definitions.yaml b/airbyte-config/init/src/main/resources/seed/source_definitions.yaml
@@ -1530,7 +1530,7 @@
 - name: Snapchat Marketing
   sourceDefinitionId: 200330b2-ea62-4d11-ac6d-cfe3e3f8ab2b
   dockerRepository: airbyte/source-snapchat-marketing
-  dockerImageTag: 0.1.8
+  dockerImageTag: 0.1.9
   documentationUrl: https://docs.airbyte.com/integrations/sources/snapchat-marketing
   icon: snapchat.svg
   sourceType: api

diff --git a/airbyte-config/init/src/main/resources/seed/source_specs.yaml b/airbyte-config/init/src/main/resources/seed/source_specs.yaml
@@ -13603,7 +13603,7 @@
     supportsNormalization: false
     supportsDBT: false
     supported_destination_sync_modes: []
-- dockerImage: "airbyte/source-snapchat-marketing:0.1.8"
+- dockerImage: "airbyte/source-snapchat-marketing:0.1.9"
   spec:
     documentationUrl: "https://docs.airbyte.com/integrations/sources/snapchat-marketing"
     connectionSpecification:

diff --git a/airbyte-integrations/connectors/source-snapchat-marketing/Dockerfile b/airbyte-integrations/connectors/source-snapchat-marketing/Dockerfile
@@ -25,5 +25,5 @@ COPY source_snapchat_marketing ./source_snapchat_marketing
 ENV AIRBYTE_ENTRYPOINT "python /airbyte/integration_code/main.py"
 ENTRYPOINT ["python", "/airbyte/integration_code/main.py"]
 
-LABEL io.airbyte.version=0.1.8
+LABEL io.airbyte.version=0.1.9
 LABEL io.airbyte.name=airbyte/source-snapchat-marketing
diff --git a/...yte-integrations/connectors/source-snapchat-marketing/source_snapchat_marketing/source.py b/...yte-integrations/connectors/source-snapchat-marketing/source_snapchat_marketing/source.py
@@ -97,7 +97,6 @@
     "earned_reach",
 ]
 
-
 logger = logging.getLogger("airbyte")
 
 
@@ -476,15 +475,15 @@ def update_state_after_last_record(self, record):
             self.number_of_last_records += 1
             # Update state if 'last' records for all dependant entities have been read
             if self.number_of_parent_ids == self.number_of_last_records:
-                self.state = record_end_date
+                self.state = {self.cursor_field: record_end_date}
 
     @property
     def state(self):
         return self._state
 
     @state.setter
     def state(self, value):
-        self._state[self.cursor_field] = value
+        self._state = value
 
     def parse_response(
         self,
@@ -498,7 +497,7 @@ def parse_response(
 
         # Update state for each date slice (start_date), it ensures that previous date slices have been read
         # and can be skipped in next incremental sync
-        self.state = stream_slice[self.cursor_field]
+        self.state = {self.cursor_field: stream_slice[self.cursor_field]}
 
         for record in super().parse_response(
             response=response, stream_state=stream_state, stream_slice=stream_slice, next_page_token=next_page_token

diff --git a/docs/integrations/sources/snapchat-marketing.md b/docs/integrations/sources/snapchat-marketing.md
@@ -113,6 +113,7 @@ Snapchat Marketing API has limitations to 1000 items per page.
 
 | Version | Date       | Pull Request                                             | Subject                                               |
 |:--------|:-----------|:---------------------------------------------------------|:------------------------------------------------------|
+| 0.1.9   | 2022-12-14 | [20498](https://github.com/airbytehq/airbyte/pull/20498)      | Fix output state when no records are read             |
 | 0.1.8   | 2022-10-05 | [17596](https://github.com/airbytehq/airbyte/pull/17596) | Retry 429 and 5xx errors when refreshing access token |
 | 0.1.6   | 2022-07-21 | [14924](https://github.com/airbytehq/airbyte/pull/14924) | Remove `additionalProperties` field from specs        |
 | 0.1.5   | 2022-07-13 | [14577](https://github.com/airbytehq/airbyte/pull/14577) | Added stats streams hourly, daily, lifetime           |