def trigger_deleteDS()

in deleteExpiredForecast/deleteExpiredForecast.py [0:0]


def trigger_deleteDS(datasetGroup):
    dsGroupArn=datasetGroup["DatasetGroupArn"]
    if(noExistingForecasts(forecast_client,dsGroupArn )):
      if(noExistingPredictors(forecast_client,dsGroupArn)):
          if(noExistingDataset(forecast_client,dsGroupArn)):
              forecast_client.delete_dataset_group(DatasetGroupArn=dsGroupArn)
              logger.info("DatasetGroup deletion triggerred, DatasetGroupArn="+dsGroupArn)