def run_sql()

in configurations/RedshiftConfigTestingLambda.py [0:0]

• 12 lines of code
• 4 McCabe index (conditional complexity)

def run_sql(clusterid, db, user, script, with_event, run_type):
    res = boto3.client("redshift-data").execute_statement(Database=db, DbUser=user, Sql=script,
                                                          ClusterIdentifier=clusterid, WithEvent=with_event)
    query_id = res["Id"]
    done = False
    while not done:
        status = sql_status(query_id)
        if run_type == 'async':
            break
        elif status == "FINISHED":
            break
    return query_id