Revert Organizations to the Incremental Search endpoint (#70)

singer-io · Sep 16, 2021 · ab9936f · ab9936f
1 parent a26eb4d
commit ab9936f
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/tap_zendesk/streams.py b/tap_zendesk/streams.py
@@ -153,11 +153,10 @@ def _add_custom_fields(self, schema):
 
     def sync(self, state):
         bookmark = self.get_bookmark(state)
-        organizations = self.get_objects()
+        organizations = self.client.organizations.incremental(start_time=bookmark)
         for organization in organizations:
-            if utils.strptime_with_tz(organization['updated_at']) >= bookmark:
-                self.update_bookmark(state, organization['updated_at'])
-                yield (self.stream, organization)
+            self.update_bookmark(state, organization.updated_at)
+            yield (self.stream, organization)
 
 
 class Users(Stream):