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

Add low priority to cli tasks

Browse Source
This commit is contained in:
Gui Heise 2022-02-21 12:45:36 -05:00
parent 5eef1b7a8f
commit 180a987a61
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
cli.py
View File

@ -14,7 +14,6 @@ from mev_inspect.inspector import MEVInspector
from mev_inspect.prices import fetch_prices, fetch_prices_range from mev_inspect.prices import fetch_prices, fetch_prices_range
from mev_inspect.queue.broker import connect_broker from mev_inspect.queue.broker import connect_broker
from mev_inspect.queue.tasks import ( from mev_inspect.queue.tasks import (
HIGH_PRIORITY,
LOW_PRIORITY, LOW_PRIORITY,
LOW_PRIORITY_QUEUE, LOW_PRIORITY_QUEUE,
backfill_export_task, backfill_export_task,
@ -169,7 +168,7 @@ def enqueue_s3_export(block_number: int):
backfill_export_task, backfill_export_task,
broker=broker, broker=broker,
queue_name=LOW_PRIORITY_QUEUE, queue_name=LOW_PRIORITY_QUEUE,
priority=HIGH_PRIORITY, priority=LOW_PRIORITY,
) )
logger.info(f"Sending block {block_number} export to queue") logger.info(f"Sending block {block_number} export to queue")
export_actor.send(block_number) export_actor.send(block_number)
@ -184,7 +183,7 @@ def enqueue_many_s3_exports(after_block: int, before_block: int):
backfill_export_task, backfill_export_task,
broker=broker, broker=broker,
queue_name=LOW_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):