Reputations object set by dedicated method

hive/indexer/blocks.py

@@ -13,7 +13,7 @@ from hive.indexer.follow import Follow
 from hive.indexer.votes import Votes
 from hive.indexer.post_data_cache import PostDataCache
 from hive.indexer.tags import Tags
-from hive.indexer.reputations import Reputations
+
 
 from time import perf_counter
 
@@ -30,12 +30,11 @@ class Blocks:
     """Processes blocks, dispatches work, manages `hive_blocks` table."""
     blocks_to_flush = []
     _head_block_date = None
-    _reputations = Reputations(DB)
+    _reputations = None
     _current_block_date = None
 
     def __init__(cls):
         log.info("Creating a reputations processor")
-        log.info("Built reputations object: {}".format(cls._reputations))
         log.info("Built blocks object: {}".format(cls))
 
         head_date = cls.head_date()
@@ -46,6 +45,12 @@ class Blocks:
             cls._head_block_date = head_date
             cls._current_block_date = head_date
 
+    @classmethod 
+    def set_reputations_processor(cls, reputations_processor):
+        cls._reputations = reputations_processor
+        assert cls._reputations is not None, "Reputation object is None"
+        log.info("Built reputations object: {}".format(cls._reputations))
+
     @classmethod
     def head_num(cls):
         """Get hive's head block number."""

hive/indexer/sync.py

 """Hive sync manager."""
 
+from hive.indexer.reputations import Reputations
 import logging
 import glob
 from time import perf_counter as perf
@@ -31,6 +32,7 @@ from hive.utils.stats import FlushStatusManager as FSM
 from hive.utils.stats import WaitingStatusManager as WSM
 from hive.utils.stats import PrometheusClient as PC
 from hive.utils.stats import BroadcastObject
+from hive.indexer.reputations import Reputations
 
 log = logging.getLogger(__name__)
 
@@ -216,7 +218,7 @@ class Sync:
 
         # ensure db schema up to date, check app status
         DbState.initialize()
-
+        Blocks.set_reputations_processor(Reputations(self._db))
         self._blocksProcessor = Blocks()
 
         # prefetch id->name and id->rank memory maps
@@ -370,7 +372,7 @@ class Sync:
             start_time = perf()
 
             self._db.query("START TRANSACTION")
-            num = blocksProcessor.process(block, {}, steemd)
+            num = self._blocksProcessor.process(block, {}, steemd)
             follows = Follow.flush(trx=False)
             accts = Accounts.flush(steemd, trx=False, spread=8)
             self._db.query("COMMIT")