diff --git a/airbyte-integrations/connectors/source-shopify/Dockerfile b/airbyte-integrations/connectors/source-shopify/Dockerfile index edb7ac03c3b0f..1e7a6898795cd 100644 --- a/airbyte-integrations/connectors/source-shopify/Dockerfile +++ b/airbyte-integrations/connectors/source-shopify/Dockerfile @@ -28,5 +28,5 @@ COPY source_shopify ./source_shopify ENV AIRBYTE_ENTRYPOINT "python /airbyte/integration_code/main.py" ENTRYPOINT ["python", "/airbyte/integration_code/main.py"] -LABEL io.airbyte.version=0.1.37 +LABEL io.airbyte.version=0.1.38 LABEL io.airbyte.name=airbyte/source-shopify diff --git a/airbyte-integrations/connectors/source-shopify/source_shopify/source.py b/airbyte-integrations/connectors/source-shopify/source_shopify/source.py index 34e6c2ebdaef5..64a296dd3219e 100644 --- a/airbyte-integrations/connectors/source-shopify/source_shopify/source.py +++ b/airbyte-integrations/connectors/source-shopify/source_shopify/source.py @@ -129,7 +129,9 @@ def filter_records_newer_than_state(self, stream_state: Mapping[str, Any] = None # Getting records >= state if stream_state: for record in records_slice: - if record.get(self.cursor_field, "") >= stream_state.get(self.cursor_field): + if record.get(self.cursor_field, "1970-01-01T00:00:00+00:00") >= stream_state.get( + self.cursor_field, "1970-01-01T00:00:00+00:00" + ): yield record else: yield from records_slice diff --git a/docs/integrations/sources/shopify.md b/docs/integrations/sources/shopify.md index 5e9a78a8625e2..cd2bfed1e75cd 100644 --- a/docs/integrations/sources/shopify.md +++ b/docs/integrations/sources/shopify.md @@ -139,6 +139,7 @@ This is expected when the connector hits the 429 - Rate Limit Exceeded HTTP Erro | Version | Date | Pull Request | Subject | |:--------| :--- | :--- | :--- | +| 0.1.38 | 2022-05-25 | [13163](https://github.com/airbytehq/airbyte/pull/13163) | Fix inconsistent comparison | | 0.1.37 | 2022-04-30 | [12500](https://github.com/airbytehq/airbyte/pull/12500) | Improve input configuration copy | | 0.1.36 | 2022-03-22 | [9850](https://github.com/airbytehq/airbyte/pull/9850) | Added `BalanceTransactions` stream | | 0.1.35 | 2022-03-07 | [10915](https://github.com/airbytehq/airbyte/pull/10915) | Fix a bug which caused `full-refresh` syncs of child REST entities configured for `incremental` |