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)