def noExistingDataImportJobs()

in deleteExpiredForecast/deleteExpiredForecast.py [0:0]

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

def noExistingDataImportJobs(client,DatasetArn):
    response = client.list_dataset_import_jobs( Filters=[
         {
            'Key': 'DatasetArn',
            'Value': DatasetArn,
            'Condition': 'IS'
         },
     ])
    numOfExistingDataImportJobs = len(response["DatasetImportJobs"])
    for importjob in response["DatasetImportJobs"]:
        importjobArn=importjob["DatasetImportJobArn"]
        client.delete_dataset_import_job(DatasetImportJobArn=importjobArn)
        logger.info("DatasetImportJob deletion triggerred, DatasetImportJob="+importjobArn)
    return (numOfExistingDataImportJobs==0)