From 5d2eb96eba9caf8107bed0a995dc7ece79dbd369 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Josu=C3=A9=20M=2E=20Sehnem?= Date: Wed, 30 Nov 2022 15:05:10 -0500 Subject: [PATCH] Remove inventory items filter --- setup.py | 2 +- tap_shopify/streams/inventory_items.py | 12 +----------- 2 files changed, 2 insertions(+), 12 deletions(-) diff --git a/setup.py b/setup.py index afce90fe..3f557660 100755 --- a/setup.py +++ b/setup.py @@ -3,7 +3,7 @@ setup( name="tap-shopify", - version="1.4.11", + version="1.4.12", description="Singer.io tap for extracting Shopify data", author="Stitch", url="http://github.com/singer-io/tap-shopify", diff --git a/tap_shopify/streams/inventory_items.py b/tap_shopify/streams/inventory_items.py index 55fe047a..89088513 100644 --- a/tap_shopify/streams/inventory_items.py +++ b/tap_shopify/streams/inventory_items.py @@ -38,17 +38,7 @@ def get_objects(self): yield inventory_item def sync(self): - bookmark = self.get_bookmark() - max_bookmark = bookmark for inventory_item in self.get_objects(): - inventory_item_dict = inventory_item.to_dict() - replication_value = strptime_to_utc(inventory_item_dict[self.replication_key]) - if replication_value >= bookmark: - yield inventory_item_dict - - if replication_value > max_bookmark: - max_bookmark = replication_value - - self.update_bookmark(strftime(max_bookmark)) + yield inventory_item.to_dict() Context.stream_objects['inventory_items'] = InventoryItems