Fixed assert test

NYPL · Dec 13, 2024 · 95f9e53 · 95f9e53
1 parent 6683bee
commit 95f9e53
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/processes/ingest/publisher_backlist.py b/processes/ingest/publisher_backlist.py
@@ -25,11 +25,11 @@ def runProcess(self):
             self.createSession()
 
             if self.process == 'daily':
-                records = self.publisher_backlist_service.get_records(limit=self.limit)
+                records = self.publisher_backlist_service.get_records(offset=self.offset, limit=self.limit)
             elif self.process == 'complete':
                 records = self.publisher_backlist_service.get_records(full_import=True)
             elif self.process == 'custom':
-                records = self.publisher_backlist_service.get_records(start_timestamp=self.ingestPeriod, offset=self.offset, limit=self.limit)
+                records = self.publisher_backlist_service.get_records(start_timestamp=self.ingestPeriod, limit=self.limit)
             else: 
                 logger.warning(f'Unknown Publisher Backlist ingestion process type {self.process}')
                 return

diff --git a/services/sources/publisher_backlist_service.py b/services/sources/publisher_backlist_service.py
@@ -131,6 +131,8 @@ def get_records_json(self,
     ) -> list[dict]:
         if offset == None:
             limit = 100
+
+        limit = offset
 
         filter_by_formula = self.build_filter_by_formula_parameter(deleted=False, full_import=None, start_timestamp=None)