def handler()

in delivery/src/table_update/main.py [0:0]

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

def handler(event, _):
    """
    Lambda function handler for Orders Table stream
    """

    # this handler may complete without publishing any metrics
    warnings.filterwarnings("ignore", "No metrics to publish*")

    metrics.add_dimension(name="environment", value=ENVIRONMENT)

    logger.debug({
        "message": "Input event",
        "event": event
    })

    logger.debug({
        "message": "Records received",
        "records": event.get("Records", [])
    })

    events = [
        process_record(record)
        for record in event.get("Records", [])
    ]
    events = [event for event in events if event is not None]

    logger.info("Received %d event(s)", len(events))
    logger.debug({
        "message": "Events processed from records",
        "events": events
    })

    if len(events) > 0:
        send_events(events)