def validate_query()

in library/n1_c360_dispositions.py [0:0]


def validate_query(client, query_id):
    resp = ["FAILED", "SUCCEEDED", "CANCELLED"]
    response = client.get_query_execution(QueryExecutionId=query_id)
    # wait until query finishes
    while response["QueryExecution"]["Status"]["State"] not in resp:
        response = client.get_query_execution(QueryExecutionId=query_id)
        time.sleep(2)
    return response["QueryExecution"]["Status"]["State"]