From cc56f2487c528c4d71163127de548949959a42d3 Mon Sep 17 00:00:00 2001 From: Hassan Syyid Date: Mon, 17 Feb 2025 00:32:58 -0500 Subject: [PATCH] Add timezone --- tap_shopify/streams/orders.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/tap_shopify/streams/orders.py b/tap_shopify/streams/orders.py index f1fb6469..9062d95e 100644 --- a/tap_shopify/streams/orders.py +++ b/tap_shopify/streams/orders.py @@ -340,7 +340,7 @@ def call_api_for_orders(self, gql_client, query, cursor=None): def get_orders(self): gql_client = shopify.GraphQL() - updated_at = self.max_bookmark.strftime('%Y-%m-%dT%H:%M:%S') + updated_at = self.max_bookmark.strftime('%Y-%m-%dT%H:%M:%SZ') query = f"updated_at:>='{updated_at}'" page = self.call_api_for_orders(gql_client, query) @@ -357,8 +357,8 @@ def get_orders(self): yield page # Every 1,000 orders we will reset the cursor - if self.orders % 1_000 == 0 and updated_at != self.max_bookmark.strftime('%Y-%m-%dT%H:%M:%S'): - updated_at = self.max_bookmark.strftime('%Y-%m-%dT%H:%M:%S') + if self.orders % 1_000 == 0 and updated_at != self.max_bookmark.strftime('%Y-%m-%dT%H:%M:%SZ'): + updated_at = self.max_bookmark.strftime('%Y-%m-%dT%H:%M:%SZ') query = f"updated_at:>='{updated_at}'" cursor = None