LICENSE
README.md
pyproject.toml
src/lakehouse_plumber.egg-info/PKG-INFO
src/lakehouse_plumber.egg-info/SOURCES.txt
src/lakehouse_plumber.egg-info/dependency_links.txt
src/lakehouse_plumber.egg-info/entry_points.txt
src/lakehouse_plumber.egg-info/requires.txt
src/lakehouse_plumber.egg-info/top_level.txt
src/lhp/__init__.py
src/lhp/bundle/__init__.py
src/lhp/bundle/databricks_yaml_manager.py
src/lhp/bundle/error_factories.py
src/lhp/bundle/exceptions.py
src/lhp/bundle/manager.py
src/lhp/bundle/template_fetcher.py
src/lhp/cli/__init__.py
src/lhp/cli/error_boundary.py
src/lhp/cli/main.py
src/lhp/cli/commands/__init__.py
src/lhp/cli/commands/base_command.py
src/lhp/cli/commands/dependencies_command.py
src/lhp/cli/commands/generate_command.py
src/lhp/cli/commands/init_command.py
src/lhp/cli/commands/list_commands.py
src/lhp/cli/commands/show_command.py
src/lhp/cli/commands/state_command.py
src/lhp/cli/commands/stats_command.py
src/lhp/cli/commands/validate_command.py
src/lhp/core/__init__.py
src/lhp/core/action_registry.py
src/lhp/core/base_generator.py
src/lhp/core/commands.py
src/lhp/core/config_field_validator.py
src/lhp/core/dependency_resolver.py
src/lhp/core/dlt_cdc_validators.py
src/lhp/core/factories.py
src/lhp/core/init_template_context.py
src/lhp/core/init_template_loader.py
src/lhp/core/layers.py
src/lhp/core/orchestrator.py
src/lhp/core/parallel_processor.py
src/lhp/core/project_config_loader.py
src/lhp/core/secret_validator.py
src/lhp/core/state_dependency_resolver.py
src/lhp/core/state_manager.py
src/lhp/core/state_models.py
src/lhp/core/strategies.py
src/lhp/core/template_engine.py
src/lhp/core/validator.py
src/lhp/core/services/__init__.py
src/lhp/core/services/code_generator.py
src/lhp/core/services/dependency_analyzer.py
src/lhp/core/services/dependency_output_manager.py
src/lhp/core/services/flowgroup_discoverer.py
src/lhp/core/services/flowgroup_processor.py
src/lhp/core/services/generation_planning_service.py
src/lhp/core/services/job_generator.py
src/lhp/core/services/job_name_validator.py
src/lhp/core/services/monitoring_pipeline_builder.py
src/lhp/core/services/operational_metadata_service.py
src/lhp/core/services/pipeline_config_loader.py
src/lhp/core/services/pipeline_validator.py
src/lhp/core/state/__init__.py
src/lhp/core/state/dependency_tracker.py
src/lhp/core/state/state_analyzer.py
src/lhp/core/state/state_cleanup_service.py
src/lhp/core/state/state_persistence.py
src/lhp/core/validators/__init__.py
src/lhp/core/validators/base_validator.py
src/lhp/core/validators/load_validator.py
src/lhp/core/validators/table_creation_validator.py
src/lhp/core/validators/test_validator.py
src/lhp/core/validators/transform_validator.py
src/lhp/core/validators/write_validator.py
src/lhp/generators/__init__.py
src/lhp/generators/load/__init__.py
src/lhp/generators/load/cloudfiles.py
src/lhp/generators/load/custom_datasource.py
src/lhp/generators/load/delta.py
src/lhp/generators/load/jdbc.py
src/lhp/generators/load/kafka.py
src/lhp/generators/load/python.py
src/lhp/generators/load/sql.py
src/lhp/generators/test/__init__.py
src/lhp/generators/test/test_generator.py
src/lhp/generators/transform/__init__.py
src/lhp/generators/transform/data_quality.py
src/lhp/generators/transform/python.py
src/lhp/generators/transform/python_file_copier.py
src/lhp/generators/transform/schema.py
src/lhp/generators/transform/sql.py
src/lhp/generators/transform/temp_table.py
src/lhp/generators/write/__init__.py
src/lhp/generators/write/materialized_view.py
src/lhp/generators/write/sink.py
src/lhp/generators/write/streaming_table.py
src/lhp/generators/write/sinks/__init__.py
src/lhp/generators/write/sinks/base_sink.py
src/lhp/generators/write/sinks/custom_sink.py
src/lhp/generators/write/sinks/delta_sink.py
src/lhp/generators/write/sinks/foreachbatch_sink.py
src/lhp/generators/write/sinks/kafka_sink.py
src/lhp/models/__init__.py
src/lhp/models/config.py
src/lhp/models/dependencies.py
src/lhp/parsers/__init__.py
src/lhp/parsers/yaml_parser.py
src/lhp/presets/__init__.py
src/lhp/presets/preset_manager.py
src/lhp/schemas/README.md
src/lhp/schemas/flowgroup.schema.json
src/lhp/schemas/preset.schema.json
src/lhp/schemas/project.schema.json
src/lhp/schemas/substitution.schema.json
src/lhp/schemas/template.schema.json
src/lhp/services/__init__.py
src/lhp/services/state_display_service.py
src/lhp/services/state_display_utils.py
src/lhp/templates/base.py.j2
src/lhp/templates/bundle/job_resource.yml.j2
src/lhp/templates/bundle/master_job_resource.yml.j2
src/lhp/templates/bundle/pipeline_resource.yml.j2
src/lhp/templates/init/README.md.j2
src/lhp/templates/init/lhp.yaml.j2
src/lhp/templates/init/bundle/databricks.yml.j2
src/lhp/templates/init/config/job_config_env.yaml.tmpl
src/lhp/templates/init/config/pipeline_config_env.yaml.tmpl
src/lhp/templates/init/expectations/customer_quality.json.tmpl
src/lhp/templates/init/pipelines/01_raw_ingestion/csv_ingestions/customer_ingestion.yaml.tmpl
src/lhp/templates/init/pipelines/01_raw_ingestion/csv_ingestions/orders_ingestion.yaml.tmpl
src/lhp/templates/init/pipelines/02_bronze/customer_bronze.yaml.tmpl
src/lhp/templates/init/pipelines/02_bronze/orders_bronze.yaml.tmpl
src/lhp/templates/init/pipelines/03_silver/dim/customer_silver_dim.yaml.tmpl
src/lhp/templates/init/pipelines/03_silver/fct/orders_silver_fct.yaml.tmpl
src/lhp/templates/init/presets/bronze_layer.yaml.tmpl
src/lhp/templates/init/schema_transforms/lineitem_bronze_schema.yaml.tmpl
src/lhp/templates/init/schema_transforms/orders_africa_bronze_schema.yaml.tmpl
src/lhp/templates/init/schemas/customer_schema.ddl.tmpl
src/lhp/templates/init/schemas/customer_schema.yaml.tmpl
src/lhp/templates/init/schemas/orders_schema.yaml.tmpl
src/lhp/templates/init/sql/orders_europe_bronze_cleanse.sql.tmpl
src/lhp/templates/init/substitutions/dev.yaml.tmpl
src/lhp/templates/init/substitutions/prod.yaml.tmpl
src/lhp/templates/init/substitutions/tst.yaml.tmpl
src/lhp/templates/init/templates/standard_ingestion.yaml.tmpl
src/lhp/templates/load/cloudfiles.py.j2
src/lhp/templates/load/custom_datasource.py.j2
src/lhp/templates/load/delta.py.j2
src/lhp/templates/load/jdbc.py.j2
src/lhp/templates/load/kafka.py.j2
src/lhp/templates/load/python.py.j2
src/lhp/templates/load/sql.py.j2
src/lhp/templates/monitoring/jobs_stats_loader.py
src/lhp/templates/transform/data_quality.py.j2
src/lhp/templates/transform/python.py.j2
src/lhp/templates/transform/schema.py.j2
src/lhp/templates/transform/sql.py.j2
src/lhp/templates/transform/temp_table.py.j2
src/lhp/templates/write/materialized_view.py.j2
src/lhp/templates/write/streaming_table.py.j2
src/lhp/utils/__init__.py
src/lhp/utils/bundle_detection.py
src/lhp/utils/dqe.py
src/lhp/utils/error_formatter.py
src/lhp/utils/exit_codes.py
src/lhp/utils/external_file_loader.py
src/lhp/utils/file_pattern_matcher.py
src/lhp/utils/formatter.py
src/lhp/utils/import_manager.py
src/lhp/utils/kafka_validator.py
src/lhp/utils/local_variables.py
src/lhp/utils/operational_metadata.py
src/lhp/utils/path_utils.py
src/lhp/utils/python_parser.py
src/lhp/utils/schema_parser.py
src/lhp/utils/schema_transform_parser.py
src/lhp/utils/secret_code_generator.py
src/lhp/utils/smart_file_writer.py
src/lhp/utils/source_extractor.py
src/lhp/utils/sql_parser.py
src/lhp/utils/substitution.py
src/lhp/utils/template_renderer.py
src/lhp/utils/version.py
src/lhp/utils/yaml_loader.py
tests/test_action_registry.py
tests/test_action_validators_kafka.py
tests/test_advanced_features.py
tests/test_append_flow.py
tests/test_base_generator.py
tests/test_base_generator_import_manager.py
tests/test_bundle_database_extraction.py
tests/test_bundle_detection.py
tests/test_bundle_environment.py
tests/test_bundle_full_substitution.py
tests/test_bundle_jinja2.py
tests/test_bundle_manager.py
tests/test_bundle_manager_catalog_schema_config.py
tests/test_bundle_manager_conservative.py
tests/test_bundle_manager_force_regeneration.py
tests/test_cdc_table_creation.py
tests/test_clean_architecture_layers.py
tests/test_cli.py
tests/test_cli_bundle_integration.py
tests/test_cli_comprehensive.py
tests/test_cli_deps_integration.py
tests/test_cli_deps_job_config.py
tests/test_cli_include.py
tests/test_cli_include_tests_flag.py
tests/test_cli_state_command.py
tests/test_cloudfiles_options.py
tests/test_code_generator.py
tests/test_commands.py
tests/test_composite_checksum.py
tests/test_config_validator.py
tests/test_config_validator_actions.py
tests/test_config_validator_dlt_cdc.py
tests/test_config_validator_exceptions.py
tests/test_config_validator_references.py
tests/test_config_validator_write_targets.py
tests/test_custom_datasource_generator.py
tests/test_dependencies_command.py
tests/test_dependencies_models.py
tests/test_dependency_analyzer.py
tests/test_dependency_analyzer_multi_job.py
tests/test_dependency_discovery.py
tests/test_dependency_integration.py
tests/test_dependency_output_manager.py
tests/test_dependency_resolver.py
tests/test_dqe.py
tests/test_dqe_edge_cases.py
tests/test_edge_cases.py
tests/test_environment_directories.py
tests/test_external_file_dependencies.py
tests/test_external_file_loader.py
tests/test_f_string_compatibility.py
tests/test_file_pattern_matching.py
tests/test_file_substitution.py
tests/test_flowgroup_discoverer.py
tests/test_flowgroup_processor_validation.py
tests/test_foreachbatch_sink_generator.py
tests/test_foreachbatch_sink_model.py
tests/test_foreachbatch_sink_validation.py
tests/test_formatting.py
tests/test_generate_command.py
tests/test_generation_planning_service.py
tests/test_generation_strategies.py
tests/test_granular_dependencies.py
tests/test_import_manager.py
tests/test_integration.py
tests/test_integration_e2e.py
tests/test_job_generator.py
tests/test_job_generator_multi_doc.py
tests/test_job_name_validator.py
tests/test_kafka_load_generator.py
tests/test_kafka_validator.py
tests/test_load_generators.py
tests/test_load_operational_metadata.py
tests/test_local_variables.py
tests/test_metadata_column_validation.py
tests/test_models.py
tests/test_mtime_cache.py
tests/test_multi_job_integration.py
tests/test_operational_metadata_selection.py
tests/test_orchestrator.py
tests/test_orchestrator_bundle_integration.py
tests/test_orchestrator_include.py
tests/test_orchestrator_include_tests.py
tests/test_orchestrator_init.py
tests/test_parallel_processor.py
tests/test_pipeline_config_loader.py
tests/test_pipeline_field_functionality.py
tests/test_pipeline_field_output_structure.py
tests/test_pipeline_validator.py
tests/test_preset_manager.py
tests/test_preset_template_combination.py
tests/test_project_config_include.py
tests/test_python38_compatibility.py
tests/test_python_load_substitution.py
tests/test_python_parser.py
tests/test_python_transform_substitution.py
tests/test_readmode.py
tests/test_real_world_sap_parquet.py
tests/test_resource_sync.py
tests/test_schema_transform_enforcement.py
tests/test_schema_transform_file_support.py
tests/test_schema_transform_parser.py
tests/test_secret_code_generator.py
tests/test_secret_execution.py
tests/test_secret_validator.py
tests/test_sink_action_validation.py
tests/test_sink_generators.py
tests/test_sink_model_validation.py
tests/test_smart_file_writer_checksum.py
tests/test_source_extractor.py
tests/test_sql_parser.py
tests/test_sql_transform_improvement.py
tests/test_staleness_analysis_integration.py
tests/test_staleness_detection.py
tests/test_state_dependency_resolver_sinks.py
tests/test_state_display_service.py
tests/test_state_manager.py
tests/test_state_manager_dependency_tracking.py
tests/test_state_manager_include.py
tests/test_substitution.py
tests/test_substitution_type_conversion.py
tests/test_template_array_conversion.py
tests/test_template_boolean_conversion.py
tests/test_template_engine.py
tests/test_template_fetcher.py
tests/test_template_integer_conversion.py
tests/test_template_object_conversion.py
tests/test_template_smart_detection.py
tests/test_template_string_conversion.py
tests/test_test_error_handling.py
tests/test_test_generator.py
tests/test_test_integration.py
tests/test_test_optimization.py
tests/test_test_validation.py
tests/test_transform_generators.py
tests/test_transform_operational_metadata.py
tests/test_uniqueness_filter.py
tests/test_unknown_field_validation.py
tests/test_validation_include_tests.py
tests/test_version.py
tests/test_version_enforcement.py
tests/test_windows_compatibility.py
tests/test_write_generators.py
tests/test_yaml_loader.py
tests/test_yaml_parser.py
tests/test_yaml_parser_cache.py
tests/test_yaml_parser_include.py
tests/test_yaml_parser_job_name_inheritance.py