def onEventHandler()

in trainDefaultPredictor/trainDefaultPredictor.py [0:0]

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

def onEventHandler(event, context):
    # list all the dataset Group that don't have predictor
    response = forecast_client.list_dataset_groups()
    for datasetGroup in response["DatasetGroups"]:
        DGName=datasetGroup["DatasetGroupName"]
        defaultPredictorName=datasetGroup["DatasetGroupName"]+"_Predictor"
        try:
            if(isPreditorExitInDataSetGroup(forecast_client,datasetGroup["DatasetGroupArn"],defaultPredictorName)):
               logger.info("Default predictor :" + defaultPredictorName + " already exist under DatasetGroup=" + DGName)
               continue
            config= loadconfig(DGName)
            createPredictor(forecast_client,datasetGroup["DatasetGroupArn"],defaultPredictorName, config)
        except Exception as e:
            logger.error("Failed to train dataset predictor for datasetGroup= " + DGName + ", will skip and continue")
            continue