def lambda_handler()

in lambda/async/app.py [0:0]


def lambda_handler(event, context):
    logger.info(event)

    # Failures will go to the configured Lambda Destination after retries
    if 'error' in event['detail']['id']:
        logger.error(event)
        raise Exception("Test")