def wait_for_ml_lookback()

in nyc_taxis/workload.py [0:0]

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

def wait_for_ml_lookback(es, params):
    while True:
        response = es.xpack.ml.get_datafeed_stats(datafeed_id=params["datafeed-id"])
        if response["datafeeds"][0]["state"] == "stopped":
            break
        time.sleep(5)