Implemented pandas-based cleaning rules in data_preprocessing.py, transformations for salesorder.csv → clean_salesorder.csv, pipeline testing via multiple DAG runs.

An end-to-end ETL pipeline that unifies marketing data from Google Analytics 4, social media platforms, and CRM systems into a BigQuery data warehouse, exposed via a FastAPI REST API for analytics and ...