def get_historical_record_count()

in pipeline_utils.py [0:0]

• 6 lines of code
• 1 McCabe index (conditional complexity)

def get_historical_record_count(fg_name, s3_uri=None):
    _table, _database, _tmp_uri = _get_offline_details(fg_name, s3_uri)
    print(_database)
    _query_string = f'SELECT COUNT(*) FROM "' +_table+ f'"'
    _tmp_df = _run_query(_query_string, _tmp_uri, _database, verbose=True)
    return _tmp_df.iat[0, 0]