"""Lambda module.""" from content_utils.logging.logger import ContentLambdaLogger import sentry_sdk from sentry_sdk.integrations.aws_lambda import AwsLambdaIntegration from src import config from src.exceptions import ProductNotSubmittedException from src.logic import complete_product if config.SENTRY_DSN: sentry_sdk.init( dsn=config.SENTRY_DSN, environment=config.ENVIRONMENT, integrations=[AwsLambdaIntegration(timeout_warning=True)] ) lambda_logger = ContentLambdaLogger(config.app_logger) def handler(event, context): """Lambda Entry point.""" lambda_logger.start() lambda_logger.set_data(**event) try: complete_product.complete_product_digital( event.get('resolution'), event.get('product_id'), event.get('will_not_deliver')) lambda_logger.set_data( status='success', result='Completed review of product in ows-product-digital') except ProductNotSubmittedException as e: lambda_logger.set_data(status='skip', result=str(e)) except Exception as e: lambda_logger.set_data(status='error', result=str(e)) raise e finally: lambda_logger.end() return {'status': lambda_logger.data.get('status')}