From cbad9e79b625df9428ecb9d1f7b9a7673d874a2d Mon Sep 17 00:00:00 2001 From: Gui Heise Date: Mon, 21 Feb 2022 10:55:26 -0500 Subject: [PATCH] Separate tasks --- mev_inspect/queue/tasks.py | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/mev_inspect/queue/tasks.py b/mev_inspect/queue/tasks.py index f7c9272..51359a6 100644 --- a/mev_inspect/queue/tasks.py +++ b/mev_inspect/queue/tasks.py @@ -37,6 +37,16 @@ def export_block_task(block_number: int): export_block(inspect_db_session, block_number) +def realtime_export_task(block_number: int): + with _session_scope(DbMiddleware.get_inspect_sessionmaker()) as inspect_db_session: + export_block(inspect_db_session, block_number) + + +def backfill_export_task(block_number: int): + with _session_scope(DbMiddleware.get_inspect_sessionmaker()) as inspect_db_session: + export_block(inspect_db_session, block_number) + + @contextmanager def _session_scope(Session=None): if Session is None: