From b486d53012db0d4d27abd8e4fd5fe3d87bd9784e Mon Sep 17 00:00:00 2001 From: Gui Heise Date: Thu, 17 Feb 2022 11:59:29 -0500 Subject: [PATCH] Remove priorities --- cli.py | 4 ++-- worker.py | 6 +----- 2 files changed, 3 insertions(+), 7 deletions(-) diff --git a/cli.py b/cli.py index fb3ec4e..e03de61 100644 --- a/cli.py +++ b/cli.py @@ -184,8 +184,8 @@ def enqueue_many_s3_exports(after_block: int, before_block: int): export_actor = dramatiq.actor( export_block_task, broker=broker, - queue_name=HIGH_PRIORITY_QUEUE, - priority=HIGH_PRIORITY, + queue_name=LOW_PRIORITY_QUEUE, + priority=LOW_PRIORITY, ) logger.info(f"Sending blocks {after_block} to {before_block} to queue") for block_number in range(after_block, before_block): diff --git a/worker.py b/worker.py index 7daef96..ce852f0 100644 --- a/worker.py +++ b/worker.py @@ -11,8 +11,6 @@ from mev_inspect.queue.middleware import ( InspectorMiddleware, ) from mev_inspect.queue.tasks import ( - HIGH_PRIORITY, - HIGH_PRIORITY_QUEUE, LOW_PRIORITY, LOW_PRIORITY_QUEUE, export_block_task, @@ -30,6 +28,4 @@ dramatiq.set_broker(broker) dramatiq.actor( inspect_many_blocks_task, queue_name=LOW_PRIORITY_QUEUE, priority=LOW_PRIORITY ) -dramatiq.actor( - export_block_task, queue_name=HIGH_PRIORITY_QUEUE, priority=HIGH_PRIORITY -) +dramatiq.actor(export_block_task)