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

Add export task

Browse Source
This commit is contained in:
Gui Heise 2022-02-11 16:47:24 -05:00
parent 9dbe68b284
commit bb06c8a958
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
mev_inspect/queue/tasks.py
View File

@ -2,6 +2,8 @@ import asyncio
import logging import logging
from contextlib import contextmanager from contextlib import contextmanager
from mev_inspect.s3_export import export_block
from .middleware import DbMiddleware, InspectorMiddleware from .middleware import DbMiddleware, InspectorMiddleware
logger = logging.getLogger(__name__) logger = logging.getLogger(__name__)
@ -23,6 +25,11 @@ def inspect_many_blocks_task(
) )
def export_block_task(block_number: int):
with _session_scope(DbMiddleware.get_inspect_sessionmaker()) as inspect_db_session:
export_block(inspect_db_session, block_number)
@contextmanager @contextmanager
def _session_scope(Session=None): def _session_scope(Session=None):
if Session is None: if Session is None: