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

Remove priorities

Browse Source
This commit is contained in:
Gui Heise 2022-02-17 11:59:29 -05:00
parent fe9253ca5e
commit b486d53012
2 changed files with 3 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
cli.py
View File

@ -184,8 +184,8 @@ def enqueue_many_s3_exports(after_block: int, before_block: int):
export_actor = dramatiq.actor( export_actor = dramatiq.actor(
export_block_task, export_block_task,
broker=broker, broker=broker,
queue_name=HIGH_PRIORITY_QUEUE, queue_name=LOW_PRIORITY_QUEUE,
priority=HIGH_PRIORITY, priority=LOW_PRIORITY,
) )
logger.info(f"Sending blocks {after_block} to {before_block} to queue") logger.info(f"Sending blocks {after_block} to {before_block} to queue")
for block_number in range(after_block, before_block): for block_number in range(after_block, before_block):

6
worker.py
View File

@ -11,8 +11,6 @@ from mev_inspect.queue.middleware import (
InspectorMiddleware, InspectorMiddleware,
) )
from mev_inspect.queue.tasks import ( from mev_inspect.queue.tasks import (
HIGH_PRIORITY,
HIGH_PRIORITY_QUEUE,
LOW_PRIORITY, LOW_PRIORITY,
LOW_PRIORITY_QUEUE, LOW_PRIORITY_QUEUE,
export_block_task, export_block_task,
@ -30,6 +28,4 @@ dramatiq.set_broker(broker)
dramatiq.actor( dramatiq.actor(
inspect_many_blocks_task, queue_name=LOW_PRIORITY_QUEUE, priority=LOW_PRIORITY inspect_many_blocks_task, queue_name=LOW_PRIORITY_QUEUE, priority=LOW_PRIORITY
) )
dramatiq.actor( dramatiq.actor(export_block_task)
export_block_task, queue_name=HIGH_PRIORITY_QUEUE, priority=HIGH_PRIORITY
)