This commit is contained in:
Gui Heise 2022-02-18 11:52:45 -05:00
parent ca6978a693
commit 1edd39c382

View File

@ -26,9 +26,7 @@ logger = logging.getLogger(__name__)
def export_block(inspect_db_session, block_number: int) -> None: def export_block(inspect_db_session, block_number: int) -> None:
for table in supported_tables: for table in supported_tables:
_export_block_by_table(inspect_db_session, block_number, table) _export_block_by_table(inspect_db_session, block_number, table)
@ -68,11 +66,11 @@ def _export_block_by_table(inspect_db_session, block_number: int, table: str) ->
def _get_export_statement(table: str) -> str: def _get_export_statement(table: str) -> str:
return f""" return f"""
SELECT to_json({table}) SELECT to_json({table})
FROM {table} FROM {table}
WHERE WHERE
block_number = :block_number block_number = :block_number
""" """
def _get_object_size(client, bucket: str, key: str) -> Optional[int]: def _get_object_size(client, bucket: str, key: str) -> Optional[int]: