def lambda_handler()

in source/CheckJobStatusFunction/app.py [0:0]

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

def lambda_handler(event, context):
    try:
        global log_level
        log_level = str(os.environ.get('LOG_LEVEL')).upper()
        if log_level not in [
                                'DEBUG', 'INFO',
                                'WARNING', 'ERROR',
                                'CRITICAL'
                            ]:
            log_level = 'ERROR'
        logging.getLogger().setLevel(log_level)

        logging.debug(event)
        dataexchange = boto3.client(service_name='dataexchange')
        s3 = boto3.client(
            service_name='s3'
        ) 
        jobId = event['JobId']
        revisionId = event['RevisionId']
        jobresponse = dataexchange.get_job(JobId=jobId) 
        logging.debug('get job = {}'.format(jobresponse))
        jobStatus=jobresponse['State']
        datasetId=event['DataSetId']
        productId=event['ProductId']
    except Exception as e:
       logging.error(e)
       raise e
    return {
        "JobStatus": jobStatus,
        "JobId": jobId,
        "RevisionId" : revisionId,
        "DataSetId" : datasetId,
        "ProductId" : productId
    }