crowetic/mev-inspect-py
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Get RPC only where its needed

Browse Source
This commit is contained in:
Luke Van Seters 2022-01-03 11:50:38 -05:00
parent e462a16b8f
commit 5a26bde3de
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
worker.py
View File

@ -38,6 +38,8 @@ class InspectorMiddleware(Middleware):
def before_process_message( def before_process_message(
self, _broker, worker self, _broker, worker
): # pylint: disable=unused-argument ): # pylint: disable=unused-argument
rpc = os.environ["RPC_URL"]
if not hasattr(thread_local, "inspector"): if not hasattr(thread_local, "inspector"):
logger.info("Building inspector") logger.info("Building inspector")
thread_local.inspector = MEVInspector( thread_local.inspector = MEVInspector(
@ -49,7 +51,6 @@ class InspectorMiddleware(Middleware):
logger.info("Inspector already exists") logger.info("Inspector already exists")
rpc = os.environ["RPC_URL"]
broker = RedisBroker(host="redis-master", password=os.environ["REDIS_PASSWORD"]) broker = RedisBroker(host="redis-master", password=os.environ["REDIS_PASSWORD"])
broker.add_middleware(AsyncMiddleware()) broker.add_middleware(AsyncMiddleware())
broker.add_middleware(InspectorMiddleware()) broker.add_middleware(InspectorMiddleware())