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

Also add priority to listener

Browse Source
This commit is contained in:
Luke Van Seters 2022-02-15 12:01:02 -05:00
parent 7a3f3874b6
commit 2e40c8bd5e
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
listener.py
View File

@ -15,7 +15,11 @@ from mev_inspect.db import get_inspect_session, get_trace_session
from mev_inspect.inspector import MEVInspector from mev_inspect.inspector import MEVInspector
from mev_inspect.provider import get_base_provider from mev_inspect.provider import get_base_provider
from mev_inspect.queue.broker import connect_broker from mev_inspect.queue.broker import connect_broker
from mev_inspect.queue.tasks import export_block_task from mev_inspect.queue.tasks import (
HIGH_PRIORITY,
HIGH_PRIORITY_QUEUE,
export_block_task,
)
from mev_inspect.signal_handler import GracefulKiller from mev_inspect.signal_handler import GracefulKiller
logging.basicConfig(filename="listener.log", filemode="a", level=logging.INFO) logging.basicConfig(filename="listener.log", filemode="a", level=logging.INFO)
@ -41,7 +45,12 @@ async def run():
trace_db_session = get_trace_session() trace_db_session = get_trace_session()
broker = connect_broker() broker = connect_broker()
export_actor = dramatiq.actor(export_block_task, broker=broker) export_actor = dramatiq.actor(
export_block_task,
broker=broker,
queue_name=HIGH_PRIORITY_QUEUE,
priority=HIGH_PRIORITY,
)
inspector = MEVInspector(rpc) inspector = MEVInspector(rpc)
base_provider = get_base_provider(rpc) base_provider = get_base_provider(rpc)