fixes

Author: DevAlone

collectors/pages_collector.py

@@ -14,15 +14,15 @@ class PagesCollector(AbstractCollector):
     """
 
     async def load_state(self, state):
-        super(PagesCollector, self).load_state(state)
+        await super(PagesCollector, self).load_state(state)
         if "_current_page" in self.data:
             self.current_page = self.data["_current_page"]
 
         if "_pages_count" in self.data:
             self.pages_count = self.data["_pages_count"]
 
     async def save_state(self, state):
-        super(PagesCollector, self).save_state(state)
+        await super(PagesCollector, self).save_state(state)
         self.data["_current_page"] = self.current_page
         self.data["_pages_count"] = self.pages_count
 

processor.py

@@ -277,7 +277,7 @@ async def process_collector_of_state(self, collector_state):
             self.collectors_logger.exception(ex)
         finally:
             collector.last_processing_time = int(time.time())
-            await collector.set_state(collector_state)
+            await collector.save_state(collector_state)
             # TODO: save new proxies count
             await db.update(collector_state)