def execute_sql()

in use-cases/aws-lambda-redshift-event-driven-etl/LambdaRedshiftDataApiETL.py [0:0]

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

def execute_sql(client, sql_text, redshift_database, redshift_user, redshift_cluster_id, with_event=True):
    print("Executing: {}".format(sql_text))
    res = client.execute_statement(Database=redshift_database, DbUser=redshift_user, Sql=sql_text,
                                   ClusterIdentifier=redshift_cluster_id, WithEvent=with_event)
    print(res)
    query_id = res["Id"]
    done = False
    while not done:
        time.sleep(1)
        status = status_check(client, query_id)
        if status in ("STARTED", "FAILED", "FINISHED"):
            print("status is: {}".format(status))
            break
    return query_id