"""Adjustment file preparation Lambda service. Serverless data validation pipeline for processing client-uploaded adjustment files. Validates business rules, verifies data integrity, and stages records for downstream processing. Architecture: EventBridge → Lambda → DuckDB (validation) → MySQL (staging) → EventBridge Key Components: - app: Lambda handler and transaction orchestration - processor: Pipeline workflow coordinator - validators: Business rule validation engine - connectors: Database adapters (DuckDB, MySQL, Snowflake, S3) - schemas: Pydantic event and response models Data Flow: 1. EventBridge triggers Lambda with batch_id and S3 location 2. Download file from S3 with integrity verification 3. Load file and reference data into DuckDB 4. Execute validation queries against business rules 5. Export validated data as CSV to S3 6. Load data into MySQL staging table 7. Publish EventBridge response with validation results """ from src.app import handler __all__ = ['handler']