From 5a26bde3de3308a7515caa28cc12f8ae829cff0e Mon Sep 17 00:00:00 2001
From: Luke Van Seters <lukevanseters@gmail.com>
Date: Mon, 3 Jan 2022 11:50:38 -0500
Subject: [PATCH] Get RPC only where its needed

---
 worker.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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