def handler()

in functions/source/association-updater/handler.py [0:0]

• 14 lines of code
• 3 McCabe index (conditional complexity)

def handler(event, context):
    logger.debug('event is {}'.format(event))

    assets_to_update = []
    integration_points = integration_points_cache.get_all()

    try:
        for record in event['Records']:
            # Batch by 10
            lifecycle_event = json.loads(record["body"])
            logger.info(f"Message: {lifecycle_event}")
            process_event(lifecycle_event, integration_points)
            assets_to_update.append(lifecycle_event)

        sqs.send_messages(assets_to_update)

    except Exception as e:
        # Send some context about this error to Lambda Logs
        logger.error(e)
        # throw exception, do not handle. Lambda will make message visible again.
        raise e