Merge branch 'feat/single_snapshotter' into testnet_pretask

PowerLoom · Nov 24, 2023 · 4735b83 · 4735b83
2 parents 0ff4069 + cebbd9d
commit 4735b83
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/snapshotter/processor_distributor.py b/snapshotter/processor_distributor.py
@@ -121,7 +121,7 @@ def __init__(self, name, **kwargs):
             self._project_type_config_mapping[project_config.project_type] = project_config
             for proload_task in project_config.preload_tasks:
                 self._all_preload_tasks.add(proload_task)
-
+        self._last_epoch_processing_health_check = 0
         self._preloader_compute_mapping = dict()
 
     def _signal_handler(self, signum, frame):

diff --git a/snapshotter/utils/aggregation_worker.py b/snapshotter/utils/aggregation_worker.py
@@ -111,7 +111,7 @@ async def _processor_task(
                 rpc_helper=self._rpc_helper,
                 anchor_rpc_helper=self._anchor_rpc_helper,
                 ipfs_reader=self._ipfs_reader_client,
-                protocol_state_contract=self.protocol_state_contract,
+                protocol_state_contract=self._protocol_state_contract,
                 project_id=project_id,
             )
 

diff --git a/snapshotter/utils/generic_worker.py b/snapshotter/utils/generic_worker.py
@@ -86,7 +86,7 @@ def __init__(self, name, **kwargs):
         self._unique_id = f'{name}-' + keccak(text=str(uuid4())).hex()[:8]
         self._running_callback_tasks: Dict[str, asyncio.Task] = dict()
         super(GenericAsyncWorker, self).__init__(name=name, **kwargs)
-        self.protocol_state_contract = None
+        self._protocol_state_contract = None
         self._qos = 1
 
         self._rate_limiting_lua_scripts = None
@@ -273,7 +273,7 @@ async def _send_payload_commit_service_queue(
             source_chain_details = await get_source_chain_id(
                 redis_conn=self._redis_conn,
                 rpc_helper=self._anchor_rpc_helper,
-                state_contract_obj=self.protocol_state_contract,
+                state_contract_obj=self._protocol_state_contract,
             )
         except Exception as e:
             self._logger.opt(exception=True).error(