def lambda_handler()

in sendSimSummary/app.py [0:0]

• 45 lines of code
• 7 McCabe index (conditional complexity)

def lambda_handler(event, context):
    '''
        This lambda function will describe a batch of simulation jobs and look for failed tests.
        It will then return the simulation job results to CodePipeline.

        Input Event:
        { 
            arns: Array | The list of arns created in the batch simulation job.
            isDone: Boolean | If the batch simulation describe call returns complete.
            batchSimJobArn: String | The ARN of the simulation batch.
            status: String | InProgress, Success or Failed for downstream processing.
            codePipelineJobId: String | The ID of the active CodePipeline job.
        }

        Output:
        { 
            message: String | The summary of the test results.
            batchSimJobArn: String | The ARN of the simulation batch.
            codePipelineJobId: String | The ID of the active CodePipeline job.
        }
    '''

    output = {
        'message': 'No results.',
        'codePipelineJobId': event['codePipelineJobId'],
        'batchSimJobArn': event['batchSimJobArn']
    }

    # If the batch job completed, we will iterate through the tags and look for failed tests.
    if event['status'] == 'Success':
        jobs_response = client.batch_describe_simulation_job( jobs = event['arns'] )
        for job in jobs_response['jobs']:
            for key in job['tags'].keys():
                if job['tags'][key] == 'Failed':
                    output['message'] = 'One or more tests failed in simulation.'
                    code_pipeline_response = pipeline.put_job_failure_result(jobId=event['codePipelineJobId'], failureDetails={
                        'type': 'JobFailed',
                        'message': output['message']
                    })
                    return output
                    
    else:
        output['message'] = 'There was an error in the execution of one or more of your simulations.'
        code_pipeline_response = pipeline.put_job_failure_result(jobId=event['codePipelineJobId'], failureDetails={
            'type': 'JobFailed',
            'message': output['message']
        })
        return output
    
    output['message'] =  '%i simulations successfully passed tests.' % len(event['arns'])
    code_pipeline_response = pipeline.put_job_success_result(jobId=event['codePipelineJobId'], executionDetails={'summary': json.dumps(output)})

    return output