in integ/validate_cloudwatch/validator.py [0:0]
def validate_test_case(test_name, log_group, log_stream, validator_func):
print('RUNNING: ' + test_name)
response = client.get_log_events(logGroupName=log_group, logStreamName=log_stream)
# test length
if len(response['events']) != 1000:
print(str(len(response['events'])) + ' events found in CloudWatch')
sys.exit('TEST_FAILURE: incorrect number of log events found')
counter = 0
for log in response['events']:
validator_func(counter, log)
counter += 1
print('SUCCESS: ' + test_name)
return True