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")