def cache_integration_points()

in functions/source/s3-to-lifecycle-events-converter/handler.py [0:0]


def cache_integration_points(messages):
    operators = [message for message in messages if message.get('type') == 'lifecycle' and message.get('reading', {}).get('et') == 'operator_updated']

    for operator in operators:
        integration_points_dynamo.save(operator)