diff --git a/tap_shopify/streams/base.py b/tap_shopify/streams/base.py
index 343463ed..15dc41c1 100644
--- a/tap_shopify/streams/base.py
+++ b/tap_shopify/streams/base.py
@@ -164,7 +164,7 @@ def get_objects(self):
                     # Save the updated_at_max as our bookmark as we've synced all rows up in our
                     # window and can move forward. Also remove the since_id because we want to
                     # restart at 1.
-                    Context.state.get(self.name, {}).pop('since_id', None)
+                    Context.state.get('bookmarks', {}).get(self.name, {}).pop('since_id', None)
                     self.update_bookmark(utils.strftime(updated_at_max))
                     break