"""Main Handler.""" from bulk_metadata_ingester_common.utils.jitter import jitter from bulk_metadata_ingester_common.utils.logging import get_current_logger import config from config import graphql_gateway def handler(event: dict, context: object) -> dict: """Lambda Entrypoint.""" # key = event.get('key') # bucket = event.get('bucket') correlation_id = event.get('correlation_id') logger = get_current_logger( config.ENVIRONMENT, config.LAMBDA_NAME, logging_level=config.LOGGING_LEVEL, correlation_id=correlation_id) # Jitter calls - Sleep for randomness jitter(logger) graphql_gateway.set_headers( { 'Orchard-User-Id': config.OA_USER, 'Correlation-Id': correlation_id } ) # Log lambda begins message logger.info(f'handle_errors received: {event}') handle_errors(event, logger) return event def handle_errors(event: dict, logger: object) -> dict: """Handle errors.""" logger.info(f'handle_errors processed NOTHING: {event}') return event