def lambda_handler()

in functions/get_comprehend_job_status/app.py [0:0]

• 26 lines of code
• 9 McCabe index (conditional complexity)

def lambda_handler(event, context):
    jsonStateMachine = event
    
    comprehendJobsStatus = 'IN_PROGRESS'
    
    #Entities Job
    responseEntities = comprehend_cli.describe_entities_detection_job(
        JobId = jsonStateMachine['comprehend']['jobIdEntities']
    )
    entitiesJobStatus = responseEntities['EntitiesDetectionJobProperties']['JobStatus']
    
    #Key Phrases Job Status
    responseKeyPhrases = comprehend_cli.describe_key_phrases_detection_job(
        JobId= jsonStateMachine['comprehend']['jobIdKeyPhrases']
    )
    keyPhrasesJobStatus = responseKeyPhrases['KeyPhrasesDetectionJobProperties']['JobStatus']

    if(entitiesJobStatus == 'COMPLETED'): 
        jsonStateMachine['comprehend']['entitiesFileUri'] = responseEntities['EntitiesDetectionJobProperties']['OutputDataConfig']['S3Uri']

    if(keyPhrasesJobStatus == 'COMPLETED'):
        jsonStateMachine['comprehend']['keyPhrasesFileUri'] = responseKeyPhrases['KeyPhrasesDetectionJobProperties']['OutputDataConfig']['S3Uri']

    #All jobs must be complete
    if ((entitiesJobStatus == 'COMPLETED') and (keyPhrasesJobStatus == 'COMPLETED')):
        comprehendJobsStatus = 'COMPLETED'
    else:
        if ((entitiesJobStatus == 'IN_PROGRESS') or (keyPhrasesJobStatus == 'IN_PROGRESS')): 
            comprehendJobsStatus = 'IN_PROGRESS' 
        else:
            if ((entitiesJobStatus == 'SUBMITTED') or (keyPhrasesJobStatus == 'SUBMITTED')): 
                comprehendJobsStatus = 'IN_PROGRESS' 
            else: comprehendJobsStatus = 'FAILED' 
        
        
    jsonStateMachine['comprehendJobsStatus'] = comprehendJobsStatus 
    return jsonStateMachine