def validate_test_case()

in integ/validate_cloudwatch/validator.py [0:0]

• 18 lines of code
• 5 McCabe index (conditional complexity)

def validate_test_case(test_name, log_group, log_stream, validator_func):
    print('RUNNING: ' + test_name)
    try: 
        response = client.get_log_events(logGroupName=log_group, logStreamName=log_stream)
    except Exception as e:
        print(e)
        return False, 'TEST_FAILURE: API call failed'
        
    # test length
    if len(response['events']) != 1000:
        print(str(len(response['events'])) + ' events found in CloudWatch')
        return False, 'TEST_FAILURE: incorrect number of log events found'

    counter = 0
    for log in response['events']:
        success, ret_message = validator_func(counter, log)
        if not success:
            return False, ret_message

        counter += 1

    print('SUCCESS: ' + test_name)
    return True, 'Success'