LICENSE
README.md
pyproject.toml
core/__init__.py
core/airflow_runner.py
core/discovery.py
core/incremental.py
core/ingestion.py
core/lineage.py
core/metadata.py
core/notifications.py
core/observability.py
core/pipeline.py
core/quality.py
core/quality_report.py
core/quality_rules.py
core/reporting.py
core/scheduler.py
core/schema.py
core/validation.py
core/warehouse.py
core/airflow/__init__.py
core/airflow/runner.py
core/airflow/task_factory.py
core/connectors/__init__.py
core/connectors/base.py
core/connectors/registry.py
core/connectors/api/__init__.py
core/connectors/api/rest_connector.py
core/connectors/cloud/__init__.py
core/connectors/cloud/azure_connector.py
core/connectors/cloud/gcs_connector.py
core/connectors/cloud/s3_connector.py
core/connectors/formats/__init__.py
core/connectors/formats/csv_connector.py
core/connectors/formats/excel_connector.py
core/connectors/formats/json_connector.py
core/connectors/formats/parquet_connector.py
docs/USABILITY_AND_OBSERVABILITY.md
models/__init__.py
models/dataset.py
models/pipeline_run.py
openingest/__init__.py
openingest/cli.py
openingest.egg-info/PKG-INFO
openingest.egg-info/SOURCES.txt
openingest.egg-info/dependency_links.txt
openingest.egg-info/entry_points.txt
openingest.egg-info/requires.txt
openingest.egg-info/top_level.txt
openingest/templates/__init__.py
openingest/templates/project/.openingest
openingest/templates/project/README.md
openingest/templates/project/docker-compose.yml
openingest/templates/project/configs/datasets.yaml
openingest/templates/project/configs/pipeline.yaml
openingest/templates/project/configs/validation_rules.yaml
openingest/templates/project/configs/warehouse.yaml
openingest/templates/project/data/raw/.gitkeep
openingest/templates/project/plugins/.gitkeep
openingest/templates/project/reports/.gitkeep
openingest/templates/project/sql/.gitkeep
scripts/__init__.py
scripts/dashboard.py
scripts/data_quality_checks.py
scripts/ingest_customers.py
scripts/ingest_orders.py
scripts/ingest_products.py
scripts/load_warehouse.py
scripts/openingest.py
scripts/pipeline_history.py
scripts/report.py
scripts/run_pipeline.py
scripts/setup_database.py
scripts/transform_data.py
scripts/commands/__init__.py
scripts/commands/add_dataset.py
scripts/commands/airflow_cmd.py
scripts/commands/discover.py
scripts/commands/docker_cmd.py
scripts/commands/doctor.py
scripts/commands/graph.py
scripts/commands/infer.py
scripts/commands/init.py
scripts/commands/profile.py
scripts/commands/schedule.py
scripts/commands/version.py
tests/test_quality_report.py
tests/test_quality_rules.py
utils/__init__.py
utils/config.py
utils/config_loader.py
utils/db.py
utils/logger.py
utils/metadata_logger.py
utils/project.py
utils/schema_utils.py