From f13fd9fa39f9f7506d4b0156bccf4f21b0ee8fba Mon Sep 17 00:00:00 2001 From: Gui Heise Date: Wed, 16 Feb 2022 10:41:48 -0500 Subject: [PATCH] Fix task priorities --- worker.py | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/worker.py b/worker.py index 82cf349..7daef96 100644 --- a/worker.py +++ b/worker.py @@ -11,7 +11,9 @@ 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, inspect_many_blocks_task, @@ -25,5 +27,9 @@ broker.add_middleware(AsyncMiddleware()) broker.add_middleware(InspectorMiddleware(os.environ["RPC_URL"])) dramatiq.set_broker(broker) -dramatiq.actor(inspect_many_blocks_task, queue_name=HIGH_PRIORITY_QUEUE) -dramatiq.actor(export_block_task, queue_name=LOW_PRIORITY_QUEUE) +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 +)