WIP: ID Bug Fix

dv01-inc · Aug 8, 2023 · 2652870 · 2652870
1 parent 45deb26
commit 2652870
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...e-integrations/connectors/source-google-firestore/source_google_firestore/QueryHelpers.py b/...e-integrations/connectors/source-google-firestore/source_google_firestore/QueryHelpers.py
@@ -81,7 +81,7 @@ def fetch_records(self, start_at=None, cursor_value=None) -> list[dict]:
         next_start_at = documents[-1] if documents else None
 
         if next_start_at is not None:
-            logger.info(f"Fetching next batch of documents. Last document: {next_start_at['id']}")
+            logger.info(f"Fetching next batch of documents. Last document: {next_start_at[self.primary_key]}")
             return self.fetch_records(next_start_at, cursor_value)
         else:
             return data