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: