25 lines
631 B
Python
25 lines
631 B
Python
import logging
|
|
import os
|
|
import sys
|
|
|
|
import dramatiq
|
|
|
|
from mev_inspect.queue.broker import connect_broker
|
|
from mev_inspect.queue.middleware import (
|
|
AsyncMiddleware,
|
|
DbMiddleware,
|
|
InspectorMiddleware,
|
|
)
|
|
from mev_inspect.queue.tasks import export_block_task, inspect_many_blocks_task
|
|
|
|
logging.basicConfig(stream=sys.stdout, level=logging.INFO)
|
|
|
|
broker = connect_broker()
|
|
broker.add_middleware(DbMiddleware())
|
|
broker.add_middleware(AsyncMiddleware())
|
|
broker.add_middleware(InspectorMiddleware(os.environ["RPC_URL"]))
|
|
dramatiq.set_broker(broker)
|
|
|
|
dramatiq.actor(inspect_many_blocks_task)
|
|
dramatiq.actor(export_block_task)
|