def process_athena_scheduler_event()

in source/log_parser/log-parser.py [0:0]

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

def process_athena_scheduler_event(log, event):
    log.debug('[process_athena_scheduler_event] Start')

    log_type = str(environ['LOG_TYPE'].upper())

    # Execute athena query for CloudFront or ALB logs
    if event['resourceType'] == 'LambdaAthenaAppLogParser' \
            and (log_type == 'CLOUDFRONT' or log_type == 'ALB'):
        execute_athena_query(log, log_type, event)

    # Execute athena query for WAF logs
    if event['resourceType'] == 'LambdaAthenaWAFLogParser':
        execute_athena_query(log, 'WAF', event)

    log.debug('[process_athena_scheduler_event] End')