def onEventHandler()

in generateForecastExport/generateForecastExport.py [0:0]

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

def onEventHandler(event, context):
    # list all the dataset Group that don't have predictor
    response = forecast_client.list_forecasts( Filters=
       [ { "Condition": "IS", "Key": "Status", "Value": "ACTIVE" } ])
    for forecast in response["Forecasts"]:
        defaultExportJob=forecast["ForecastName"]+"_export"
        if(isExportJobExistforForcast(forecast_client, defaultExportJob, forecast["ForecastArn"])):
          logger.info("default export job :" + defaultExportJob + " already exist")
          continue
        DatasetGrupName=forecast["ForecastName"].replace("_forecast","")
        exportFileKey="s3://"+S3BucketName+"/ForecastExports/"+DatasetGrupName
        createExportJob(forecast_client,defaultExportJob,forecast["ForecastArn"], exportFileKey)
        logger.info("triggerred export job :" + defaultExportJob + ", datasetGroupName=" + DatasetGrupName + "forecastArn=" + forecast["ForecastArn"])