def get_table_info_from_revision_record()

in src/qldb_streaming_to_es_sample/helpers/filtered_records_generator.py [0:0]

• 3 lines of code
• 3 McCabe index (conditional complexity)

def get_table_info_from_revision_record(revision_record):
    """
    Retrieves the table information block from revision Revision Record
    Table information contains the table name and table id

    Parameters:
       revision_record (string): The ion representation of Revision record from QLDB Streams
    """

    if ("payload" in revision_record) and "tableInfo" in revision_record["payload"]:
        return revision_record["payload"]["tableInfo"]