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

Add some logging

Browse Source
This commit is contained in:
Luke Van Seters 2021-12-31 16:18:17 -05:00
parent 01bb566478
commit 0516fffa9c
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
worker.py
View File

@ -1,5 +1,7 @@
import asyncio import asyncio
import logging
import os import os
import sys
import threading import threading
from contextlib import contextmanager from contextlib import contextmanager
@ -15,6 +17,8 @@ InspectSession = get_inspect_sessionmaker()
TraceSession = get_trace_sessionmaker() TraceSession = get_trace_sessionmaker()
thread_local = threading.local() thread_local = threading.local()
logging.basicConfig(stream=sys.stdout, level=logging.INFO)
logger = logging.getLogger(__name__)
class AsyncMiddleware(Middleware): class AsyncMiddleware(Middleware):
@ -35,11 +39,14 @@ class InspectorMiddleware(Middleware):
self, _broker, worker self, _broker, worker
): # pylint: disable=unused-argument ): # pylint: disable=unused-argument
if not hasattr(thread_local, "inspector"): if not hasattr(thread_local, "inspector"):
logger.info("Building inspector")
thread_local.inspector = MEVInspector( thread_local.inspector = MEVInspector(
rpc, rpc,
max_concurrency=5, max_concurrency=5,
request_timeout=300, request_timeout=300,
) )
else:
logger.info("Inspector already exists")
rpc = os.environ["RPC_URL"] rpc = os.environ["RPC_URL"]