def noExistingPredictors()

in deleteExpiredForecast/deleteExpiredForecast.py [0:0]


def noExistingPredictors(client,datasetGroupArn):
    response = client.list_predictors( Filters=[
         {
            'Key': 'DatasetGroupArn',
            'Value': datasetGroupArn,
            'Condition': 'IS'
         },
     ])
    numOfExistingPredictors = len(response["Predictors"])
    for predictor in response["Predictors"]:
        predictorArn=predictor["PredictorArn"]
        client.delete_predictor(PredictorArn=predictorArn)
        logger.info("Predictor deletion triggerred, PredictorArn="+predictorArn)
    return (numOfExistingPredictors==0)