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/py.typed
src/lhp/api/__init__.py
src/lhp/api/_bundle_facade.py
src/lhp/api/_claude_routing.py
src/lhp/api/_converters_common.py
src/lhp/api/_dataset_index.py
src/lhp/api/_dependency_facade.py
src/lhp/api/_dependency_graph_converters.py
src/lhp/api/_generate_stream.py
src/lhp/api/_generation_converters.py
src/lhp/api/_generation_facade.py
src/lhp/api/_inspection_converters.py
src/lhp/api/_inspection_facade.py
src/lhp/api/_listings.py
src/lhp/api/_operational_metadata_converter.py
src/lhp/api/_plan_stream.py
src/lhp/api/_preflight.py
src/lhp/api/_progress.py
src/lhp/api/_sandbox_facade.py
src/lhp/api/_sandbox_run.py
src/lhp/api/_sandbox_view.py
src/lhp/api/_serialization.py
src/lhp/api/_skill_assets.py
src/lhp/api/_skill_facade.py
src/lhp/api/_stats_builder.py
src/lhp/api/_stream_guard.py
src/lhp/api/_telemetry_shape.py
src/lhp/api/_template_preview_worker.py
src/lhp/api/_validation_converters.py
src/lhp/api/_validation_facade.py
src/lhp/api/_wheel_facade.py
src/lhp/api/bootstrap.py
src/lhp/api/configuration.py
src/lhp/api/events.py
src/lhp/api/facade.py
src/lhp/api/responses.py
src/lhp/api/templates.py
src/lhp/api/views.py
src/lhp/bundle/__init__.py
src/lhp/bundle/detection.py
src/lhp/bundle/exceptions.py
src/lhp/bundle/manager.py
src/lhp/bundle/preflight.py
src/lhp/cli/__init__.py
src/lhp/cli/_app_context.py
src/lhp/cli/_lazy_group.py
src/lhp/cli/_telemetry_hook.py
src/lhp/cli/_version.py
src/lhp/cli/console.py
src/lhp/cli/error_boundary.py
src/lhp/cli/error_panel.py
src/lhp/cli/exit_codes.py
src/lhp/cli/logging_config.py
src/lhp/cli/main.py
src/lhp/cli/commands/__init__.py
src/lhp/cli/commands/_dag_options.py
src/lhp/cli/commands/_web_launch.py
src/lhp/cli/commands/dag_command.py
src/lhp/cli/commands/diff_command.py
src/lhp/cli/commands/generate_command.py
src/lhp/cli/commands/init_command.py
src/lhp/cli/commands/inspect_wheel_command.py
src/lhp/cli/commands/list_command.py
src/lhp/cli/commands/skill_command.py
src/lhp/cli/commands/substitutions_command.py
src/lhp/cli/commands/telemetry_command.py
src/lhp/cli/commands/validate_command.py
src/lhp/cli/commands/web_command.py
src/lhp/cli/presenters/__init__.py
src/lhp/cli/presenters/_layout.py
src/lhp/cli/presenters/_style.py
src/lhp/cli/presenters/dag_files_presenter.py
src/lhp/cli/presenters/dag_presenter.py
src/lhp/cli/presenters/diff_presenter.py
src/lhp/cli/presenters/init_presenter.py
src/lhp/cli/presenters/list_presenter.py
src/lhp/cli/presenters/skill_presenter.py
src/lhp/cli/presenters/substitutions_presenter.py
src/lhp/cli/presenters/summary_presenter.py
src/lhp/cli/presenters/telemetry_presenter.py
src/lhp/cli/presenters/wheel_presenter.py
src/lhp/cli/presenters/event_stream/__init__.py
src/lhp/cli/presenters/event_stream/_event_dispatch.py
src/lhp/cli/presenters/event_stream/_flavor_words.py
src/lhp/cli/presenters/event_stream/_live_renderable.py
src/lhp/cli/presenters/event_stream/_model.py
src/lhp/cli/presenters/event_stream/_outcome.py
src/lhp/cli/presenters/event_stream/_status_line.py
src/lhp/cli/presenters/event_stream/live_renderer.py
src/lhp/cli/presenters/event_stream/log_renderer.py
src/lhp/cli/presenters/event_stream/renderer_factory.py
src/lhp/core/__init__.py
src/lhp/core/_interfaces.py
src/lhp/core/codegen/__init__.py
src/lhp/core/codegen/action_dispatch.py
src/lhp/core/codegen/assembler.py
src/lhp/core/codegen/context.py
src/lhp/core/codegen/coordinator.py
src/lhp/core/codegen/formatter.py
src/lhp/core/codegen/grouping.py
src/lhp/core/codegen/plan_builder.py
src/lhp/core/codegen/python_dependency_resolver.py
src/lhp/core/codegen/python_file_copier.py
src/lhp/core/codegen/python_import_rewriter.py
src/lhp/core/codegen/secret_code_generator.py
src/lhp/core/codegen/secrets.py
src/lhp/core/codegen/struct_type_emitter.py
src/lhp/core/codegen/template_renderer.py
src/lhp/core/codegen/test_reporting.py
src/lhp/core/codegen/tst_reporting_hook_generator.py
src/lhp/core/codegen/uc_tagging.py
src/lhp/core/codegen/uc_tagging_hook_generator.py
src/lhp/core/codegen/imports/__init__.py
src/lhp/core/codegen/imports/categorizer.py
src/lhp/core/codegen/imports/detector.py
src/lhp/core/codegen/imports/manager.py
src/lhp/core/codegen/imports/resolver.py
src/lhp/core/codegen/imports/source_parser.py
src/lhp/core/codegen/operational_metadata/__init__.py
src/lhp/core/codegen/operational_metadata/metadata.py
src/lhp/core/codegen/operational_metadata/service.py
src/lhp/core/coordination/__init__.py
src/lhp/core/coordination/_commit.py
src/lhp/core/coordination/_cross_flowgroup_issues.py
src/lhp/core/coordination/_flowgroup_pool.py
src/lhp/core/coordination/_generate_gate.py
src/lhp/core/coordination/_pool.py
src/lhp/core/coordination/_sandbox_warning_fold.py
src/lhp/core/coordination/_validation_outcome.py
src/lhp/core/coordination/_warning_merge.py
src/lhp/core/coordination/bootstrap_service.py
src/lhp/core/coordination/executor.py
src/lhp/core/coordination/flowgroup_worklist_builder.py
src/lhp/core/coordination/layers.py
src/lhp/core/coordination/monitoring_pipeline_builder.py
src/lhp/core/coordination/monitoring_service.py
src/lhp/core/coordination/orchestrator.py
src/lhp/core/coordination/sandbox_prepass.py
src/lhp/core/coordination/validation_service.py
src/lhp/core/dependencies/__init__.py
src/lhp/core/dependencies/_binding_rules.py
src/lhp/core/dependencies/_bindings.py
src/lhp/core/dependencies/_body_locator.py
src/lhp/core/dependencies/_bound_folding.py
src/lhp/core/dependencies/_call_resolution.py
src/lhp/core/dependencies/_canonical.py
src/lhp/core/dependencies/_extraction_visitor.py
src/lhp/core/dependencies/_function_index.py
src/lhp/core/dependencies/_graph_ops.py
src/lhp/core/dependencies/_parse_cache.py
src/lhp/core/dependencies/_producers.py
src/lhp/core/dependencies/_static_resolution.py
src/lhp/core/dependencies/_table_sites.py
src/lhp/core/dependencies/analyzer.py
src/lhp/core/dependencies/builder.py
src/lhp/core/dependencies/dependency_resolver.py
src/lhp/core/dependencies/graph_cache.py
src/lhp/core/dependencies/output.py
src/lhp/core/dependencies/output_writer.py
src/lhp/core/dependencies/python_parser.py
src/lhp/core/dependencies/service.py
src/lhp/core/dependencies/source_extractor.py
src/lhp/core/dependencies/source_parsing.py
src/lhp/core/dependencies/sql_extraction.py
src/lhp/core/discovery/__init__.py
src/lhp/core/discovery/_parse_pool.py
src/lhp/core/discovery/blueprint_discoverer.py
src/lhp/core/discovery/deprecation_scanner.py
src/lhp/core/discovery/flowgroup_discoverer.py
src/lhp/core/jobs/__init__.py
src/lhp/core/jobs/job_builder.py
src/lhp/core/jobs/job_generator.py
src/lhp/core/jobs/job_writer.py
src/lhp/core/loaders/__init__.py
src/lhp/core/loaders/_event_log_config_parser.py
src/lhp/core/loaders/_include_patterns_parser.py
src/lhp/core/loaders/_monitoring_config_parser.py
src/lhp/core/loaders/_operational_metadata_config_parser.py
src/lhp/core/loaders/_sandbox_config_parser.py
src/lhp/core/loaders/_test_reporting_config_parser.py
src/lhp/core/loaders/_uc_tagging_config_parser.py
src/lhp/core/loaders/_wheel_config_parser.py
src/lhp/core/loaders/external_file_loader.py
src/lhp/core/loaders/git_initializer.py
src/lhp/core/loaders/init_template_context.py
src/lhp/core/loaders/init_template_loader.py
src/lhp/core/loaders/job_config_loader.py
src/lhp/core/loaders/pipeline_config_loader.py
src/lhp/core/loaders/project_config_loader.py
src/lhp/core/loaders/sandbox_profile_loader.py
src/lhp/core/loaders/table_schema_resolver.py
src/lhp/core/loaders/version_enforcement.py
src/lhp/core/packaging/__init__.py
src/lhp/core/packaging/identity.py
src/lhp/core/packaging/packager.py
src/lhp/core/packaging/runner.py
src/lhp/core/packaging/wheel_builder.py
src/lhp/core/packaging/wheel_reader.py
src/lhp/core/processing/__init__.py
src/lhp/core/processing/blueprint_expander.py
src/lhp/core/processing/dqe.py
src/lhp/core/processing/flowgroup_resolver.py
src/lhp/core/processing/local_variables.py
src/lhp/core/processing/namespace_normalizer.py
src/lhp/core/processing/substitution.py
src/lhp/core/processing/template_authoring.py
src/lhp/core/processing/template_engine.py
src/lhp/core/processing/template_preview.py
src/lhp/core/processing/template_preview_dependencies.py
src/lhp/core/registry/__init__.py
src/lhp/core/registry/action_registry.py
src/lhp/core/registry/base_generator.py
src/lhp/core/registry/factories.py
src/lhp/core/sandbox/__init__.py
src/lhp/core/sandbox/_flowgroup_rewriter.py
src/lhp/core/sandbox/_fstring_sql.py
src/lhp/core/sandbox/_python_rewriter.py
src/lhp/core/sandbox/_renames.py
src/lhp/core/sandbox/_runtime_shim.py
src/lhp/core/sandbox/_text_rewriter.py
src/lhp/core/sandbox/scope_resolver.py
src/lhp/core/validators/__init__.py
src/lhp/core/validators/_base.py
src/lhp/core/validators/config_validator.py
src/lhp/core/validators/action/__init__.py
src/lhp/core/validators/action/_dq_transform.py
src/lhp/core/validators/action/_name_checks.py
src/lhp/core/validators/action/_schema_transform.py
src/lhp/core/validators/action/_test_requirements.py
src/lhp/core/validators/action/_write_sinks.py
src/lhp/core/validators/action/load.py
src/lhp/core/validators/action/test.py
src/lhp/core/validators/action/transform.py
src/lhp/core/validators/action/write.py
src/lhp/core/validators/compatibility/__init__.py
src/lhp/core/validators/compatibility/_cdc_fanin_messages.py
src/lhp/core/validators/compatibility/_cdc_helpers.py
src/lhp/core/validators/compatibility/cdc_config.py
src/lhp/core/validators/compatibility/cdc_fanin.py
src/lhp/core/validators/compatibility/cdc_schema.py
src/lhp/core/validators/compatibility/dlt_table_options.py
src/lhp/core/validators/compatibility/snapshot_cdc.py
src/lhp/core/validators/compatibility/table_creation.py
src/lhp/core/validators/field/__init__.py
src/lhp/core/validators/field/_field_catalog.py
src/lhp/core/validators/field/_field_suggestions.py
src/lhp/core/validators/field/config_field.py
src/lhp/core/validators/field/kafka_options.py
src/lhp/core/validators/field/secret_reference.py
src/lhp/core/validators/pipeline/__init__.py
src/lhp/core/validators/pipeline/job_name.py
src/lhp/errors/__init__.py
src/lhp/errors/categories.py
src/lhp/errors/codes.py
src/lhp/errors/factory.py
src/lhp/errors/types.py
src/lhp/generators/__init__.py
src/lhp/generators/registration.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/_base.py
src/lhp/generators/test/all_lookups_found.py
src/lhp/generators/test/completeness.py
src/lhp/generators/test/custom_expectations.py
src/lhp/generators/test/custom_sql.py
src/lhp/generators/test/range.py
src/lhp/generators/test/referential_integrity.py
src/lhp/generators/test/row_count.py
src/lhp/generators/test/schema_match.py
src/lhp/generators/test/uniqueness.py
src/lhp/generators/transform/__init__.py
src/lhp/generators/transform/data_quality.py
src/lhp/generators/transform/python.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/_schema_tags_warning.py
src/lhp/generators/write/materialized_view.py
src/lhp/generators/write/sink.py
src/lhp/generators/write/snapshot_cdc_source_function.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/_action.py
src/lhp/models/_blueprint.py
src/lhp/models/_enums.py
src/lhp/models/_flowgroup.py
src/lhp/models/_monitoring.py
src/lhp/models/_operational_metadata.py
src/lhp/models/_project.py
src/lhp/models/_quarantine.py
src/lhp/models/_sandbox.py
src/lhp/models/_template.py
src/lhp/models/_test_reporting.py
src/lhp/models/_uc_tagging.py
src/lhp/models/dependencies.py
src/lhp/models/deprecations.py
src/lhp/models/processing.py
src/lhp/parsers/__init__.py
src/lhp/parsers/blueprint_parser.py
src/lhp/parsers/parse_cache.py
src/lhp/parsers/schema_parser.py
src/lhp/parsers/schema_transform_parser.py
src/lhp/parsers/tags_file_parser.py
src/lhp/parsers/unified_schema_format.py
src/lhp/parsers/yaml_loader.py
src/lhp/parsers/yaml_parser.py
src/lhp/presets/__init__.py
src/lhp/presets/preset_manager.py
src/lhp/resources/__init__.py
src/lhp/resources/skills/__init__.py
src/lhp/resources/skills/lhp/SKILL.md
src/lhp/resources/skills/lhp/__init__.py
src/lhp/resources/skills/lhp/references/__init__.py
src/lhp/resources/skills/lhp/references/actions-load-cloudfiles.md
src/lhp/resources/skills/lhp/references/actions-load-custom-datasource.md
src/lhp/resources/skills/lhp/references/actions-load-delta.md
src/lhp/resources/skills/lhp/references/actions-load-jdbc.md
src/lhp/resources/skills/lhp/references/actions-load-kafka.md
src/lhp/resources/skills/lhp/references/actions-load-python.md
src/lhp/resources/skills/lhp/references/actions-load-sql.md
src/lhp/resources/skills/lhp/references/actions-test-all-lookups-found.md
src/lhp/resources/skills/lhp/references/actions-test-completeness.md
src/lhp/resources/skills/lhp/references/actions-test-custom-expectations.md
src/lhp/resources/skills/lhp/references/actions-test-custom-sql.md
src/lhp/resources/skills/lhp/references/actions-test-range.md
src/lhp/resources/skills/lhp/references/actions-test-referential-integrity.md
src/lhp/resources/skills/lhp/references/actions-test-row-count.md
src/lhp/resources/skills/lhp/references/actions-test-schema-match.md
src/lhp/resources/skills/lhp/references/actions-test-uniqueness.md
src/lhp/resources/skills/lhp/references/actions-transform-data-quality.md
src/lhp/resources/skills/lhp/references/actions-transform-python.md
src/lhp/resources/skills/lhp/references/actions-transform-schema.md
src/lhp/resources/skills/lhp/references/actions-transform-sql.md
src/lhp/resources/skills/lhp/references/actions-transform-temp-table.md
src/lhp/resources/skills/lhp/references/actions-write-materialized-view.md
src/lhp/resources/skills/lhp/references/actions-write-sink-custom.md
src/lhp/resources/skills/lhp/references/actions-write-sink-delta.md
src/lhp/resources/skills/lhp/references/actions-write-sink-eventhubs.md
src/lhp/resources/skills/lhp/references/actions-write-sink-foreachbatch.md
src/lhp/resources/skills/lhp/references/actions-write-sink-kafka.md
src/lhp/resources/skills/lhp/references/actions-write-streaming-table-cdc.md
src/lhp/resources/skills/lhp/references/actions-write-streaming-table-snapshot-cdc.md
src/lhp/resources/skills/lhp/references/actions-write-streaming-table-standard.md
src/lhp/resources/skills/lhp/references/advanced.md
src/lhp/resources/skills/lhp/references/best-practices.md
src/lhp/resources/skills/lhp/references/blueprints.md
src/lhp/resources/skills/lhp/references/cdc-patterns.md
src/lhp/resources/skills/lhp/references/errors.md
src/lhp/resources/skills/lhp/references/monitoring.md
src/lhp/resources/skills/lhp/references/project-config.md
src/lhp/resources/skills/lhp/references/quickstart.md
src/lhp/resources/skills/lhp/references/sandbox.md
src/lhp/resources/skills/lhp/references/templates-presets.md
src/lhp/schemas/README.md
src/lhp/schemas/blueprint.schema.json
src/lhp/schemas/flowgroup.schema.json
src/lhp/schemas/instance.schema.json
src/lhp/schemas/job_config.schema.json
src/lhp/schemas/pipeline_config.schema.json
src/lhp/schemas/preset.schema.json
src/lhp/schemas/project.schema.json
src/lhp/schemas/schema.schema.json
src/lhp/schemas/substitution.schema.json
src/lhp/schemas/template.schema.json
src/lhp/schemas/help/flowgroup.json
src/lhp/schemas/help/job_config.json
src/lhp/schemas/help/pipeline_config.json
src/lhp/schemas/help/project.json
src/lhp/schemas/help/source-review.json
src/lhp/schemas/help/template.json
src/lhp/telemetry/__init__.py
src/lhp/telemetry/_client.py
src/lhp/telemetry/_consent.py
src/lhp/telemetry/_environment.py
src/lhp/telemetry/_events.py
src/lhp/telemetry/_identity.py
src/lhp/telemetry/_paths.py
src/lhp/telemetry/_preferences.py
src/lhp/telemetry/_project_shape.py
src/lhp/telemetry/_sender.py
src/lhp/telemetry/_spool.py
src/lhp/telemetry/_store.py
src/lhp/telemetry/_update_check.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/monitoring_job_resource.yml.j2
src/lhp/templates/bundle/pipeline_resource.yml.j2
src/lhp/templates/bundle/wheels_bundle.yml.j2
src/lhp/templates/init/.gitignore.j2
src/lhp/templates/init/README.md.j2
src/lhp/templates/init/lhp.yaml.j2
src/lhp/templates/init/blueprints/BP001_example_system_bronze.yaml.tmpl
src/lhp/templates/init/bundle/databricks.yml.j2
src/lhp/templates/init/bundle/resources/.gitkeep
src/lhp/templates/init/config/job_config_env.yaml.tmpl
src/lhp/templates/init/config/monitoring_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/pipelines/example_system/bronze/example_system_bronze_acme_BP001.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/init_sample/.gitignore.j2
src/lhp/templates/init_sample/README.md.j2
src/lhp/templates/init_sample/lhp.yaml.j2
src/lhp/templates/init_sample/bundle/databricks.yml.j2
src/lhp/templates/init_sample/bundle/resources/sample_job.yml
src/lhp/templates/init_sample/config/job_config_env.yaml
src/lhp/templates/init_sample/config/monitoring_job_config.yaml
src/lhp/templates/init_sample/config/pipeline_config.yaml
src/lhp/templates/init_sample/examples_optional/jdbc_with_secret.yaml.txt
src/lhp/templates/init_sample/expectations/orders.yaml
src/lhp/templates/init_sample/functions/supplier_snapshot.py
src/lhp/templates/init_sample/notebooks/data_prep.py
src/lhp/templates/init_sample/pipelines/01_ingest/lineitem_ingest.yaml
src/lhp/templates/init_sample/pipelines/01_ingest/nation_region.yaml
src/lhp/templates/init_sample/pipelines/01_ingest/orders_ingest.yaml
src/lhp/templates/init_sample/pipelines/02_silver/dim_customer.yaml
src/lhp/templates/init_sample/pipelines/02_silver/dim_supplier.yaml
src/lhp/templates/init_sample/pipelines/02_silver/orders_clean.yaml
src/lhp/templates/init_sample/pipelines/03_gold/sales_by_nation.yaml
src/lhp/templates/init_sample/presets/bronze_layer.yaml
src/lhp/templates/init_sample/presets/silver_quality.yaml
src/lhp/templates/init_sample/schema_transforms/orders_typed.yaml
src/lhp/templates/init_sample/schemas/orders_hints.yaml
src/lhp/templates/init_sample/sql/sales_by_nation.sql
src/lhp/templates/init_sample/substitutions/dev.yaml
src/lhp/templates/init_sample/substitutions/prod.yaml
src/lhp/templates/init_sample/templates/cloudfiles_ingest.yaml
src/lhp/templates/init_sample/transforms/normalize_tz.py
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/load/struct_type.py.j2
src/lhp/templates/monitoring/jobs_stats_loader.py
src/lhp/templates/monitoring/union_event_logs.py.j2
src/lhp/templates/packaging/runner.py.j2
src/lhp/templates/sandbox/runtime_shim.py.j2
src/lhp/templates/test/all_lookups_found.py.j2
src/lhp/templates/test/completeness.py.j2
src/lhp/templates/test/custom_expectations.py.j2
src/lhp/templates/test/custom_sql.py.j2
src/lhp/templates/test/range.py.j2
src/lhp/templates/test/referential_integrity.py.j2
src/lhp/templates/test/row_count.py.j2
src/lhp/templates/test/schema_match.py.j2
src/lhp/templates/test/uniqueness.py.j2
src/lhp/templates/test_reporting/hook.py.j2
src/lhp/templates/transform/data_quality.py.j2
src/lhp/templates/transform/data_quality_quarantine.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/uc_tagging/hook.py.j2
src/lhp/templates/write/materialized_view.py.j2
src/lhp/templates/write/streaming_table.py.j2
src/lhp/templates/write/sinks/custom_sink.py.j2
src/lhp/templates/write/sinks/delta_sink.py.j2
src/lhp/templates/write/sinks/foreachbatch_sink.py.j2
src/lhp/templates/write/sinks/kafka_sink.py.j2
src/lhp/utils/__init__.py
src/lhp/utils/env_flags.py
src/lhp/utils/file_header.py
src/lhp/utils/file_pattern_matcher.py
src/lhp/utils/performance_timer.py
src/lhp/utils/python_spans.py
src/lhp/utils/version.py
src/lhp/utils/yaml_filters.py
src/lhp/webapp/__init__.py
src/lhp/webapp/app.py
src/lhp/webapp/dependencies.py
src/lhp/webapp/settings.py
src/lhp/webapp/static_app.py
src/lhp/webapp/middleware/__init__.py
src/lhp/webapp/middleware/error_handler.py
src/lhp/webapp/middleware/origin_guard.py
src/lhp/webapp/middleware/request_logging.py
src/lhp/webapp/middleware/telemetry_session.py
src/lhp/webapp/middleware/token_guard.py
src/lhp/webapp/routers/__init__.py
src/lhp/webapp/routers/_guards.py
src/lhp/webapp/routers/assistant.py
src/lhp/webapp/routers/assistant_config.py
src/lhp/webapp/routers/assistant_sessions.py
src/lhp/webapp/routers/blueprints.py
src/lhp/webapp/routers/config_templates.py
src/lhp/webapp/routers/configuration.py
src/lhp/webapp/routers/dependencies.py
src/lhp/webapp/routers/environments.py
src/lhp/webapp/routers/events.py
src/lhp/webapp/routers/files.py
src/lhp/webapp/routers/flowgroups.py
src/lhp/webapp/routers/health.py
src/lhp/webapp/routers/help.py
src/lhp/webapp/routers/lineage.py
src/lhp/webapp/routers/metadata.py
src/lhp/webapp/routers/pipelines.py
src/lhp/webapp/routers/presets.py
src/lhp/webapp/routers/project.py
src/lhp/webapp/routers/runs.py
src/lhp/webapp/routers/sandbox.py
src/lhp/webapp/routers/schemas.py
src/lhp/webapp/routers/streaming.py
src/lhp/webapp/routers/tables.py
src/lhp/webapp/routers/telemetry.py
src/lhp/webapp/routers/templates.py
src/lhp/webapp/schemas/__init__.py
src/lhp/webapp/schemas/assistant.py
src/lhp/webapp/schemas/blueprint.py
src/lhp/webapp/schemas/common.py
src/lhp/webapp/schemas/configuration.py
src/lhp/webapp/schemas/dependency.py
src/lhp/webapp/schemas/flowgroup.py
src/lhp/webapp/schemas/health.py
src/lhp/webapp/schemas/lineage.py
src/lhp/webapp/schemas/metadata.py
src/lhp/webapp/schemas/pipeline.py
src/lhp/webapp/schemas/preset.py
src/lhp/webapp/schemas/project.py
src/lhp/webapp/schemas/runs.py
src/lhp/webapp/schemas/sandbox.py
src/lhp/webapp/schemas/table.py
src/lhp/webapp/schemas/telemetry.py
src/lhp/webapp/schemas/template.py
src/lhp/webapp/schemas/template_authoring.py
src/lhp/webapp/services/__init__.py
src/lhp/webapp/services/_telemetry_events.py
src/lhp/webapp/services/assistant_chat.py
src/lhp/webapp/services/assistant_provision.py
src/lhp/webapp/services/assistant_store.py
src/lhp/webapp/services/assistant_usage.py
src/lhp/webapp/services/claude_sdk_auth.py
src/lhp/webapp/services/claude_sdk_bash_policy.py
src/lhp/webapp/services/claude_sdk_bridge.py
src/lhp/webapp/services/claude_sdk_chat.py
src/lhp/webapp/services/claude_sdk_policy.py
src/lhp/webapp/services/claude_sdk_sessions.py
src/lhp/webapp/services/claude_sdk_translate.py
src/lhp/webapp/services/dataset_index.py
src/lhp/webapp/services/event_bus.py
src/lhp/webapp/services/file_io.py
src/lhp/webapp/services/file_kinds.py
src/lhp/webapp/services/file_watcher.py
src/lhp/webapp/services/graph_serializer.py
src/lhp/webapp/services/omnigent_client.py
src/lhp/webapp/services/omnigent_lifecycle.py
src/lhp/webapp/services/related_files_extractor.py
src/lhp/webapp/services/run_history.py
src/lhp/webapp/services/run_recorder.py
src/lhp/webapp/services/sqlite_migrations.py
src/lhp/webapp/services/sqlite_store.py
src/lhp/webapp/services/stream_adapter.py
src/lhp/webapp/services/telemetry_sessions.py
src/lhp/webapp/static/favicon.svg
src/lhp/webapp/static/index.html
src/lhp/webapp/static/assets/AssistantPanel-CPqV7kXN.js
src/lhp/webapp/static/assets/CodeView-AF_z0YIh.js
src/lhp/webapp/static/assets/ConfigFormView-DoY5Fd2p.js
src/lhp/webapp/static/assets/CreateFlowgroupDialog-D4o3-ikQ.js
src/lhp/webapp/static/assets/CreateFromTemplateDialog-CxlmNuO2.js
src/lhp/webapp/static/assets/CreateTemplateDialog-C-8RNPMZ.js
src/lhp/webapp/static/assets/DependencyGraph-DndBcck_.js
src/lhp/webapp/static/assets/DiffEditorWrapper-1cT0pjog.js
src/lhp/webapp/static/assets/EnumSelect-CJrYfqOU.js
src/lhp/webapp/static/assets/FieldHelpBody-BqCveWM8.js
src/lhp/webapp/static/assets/GraphView-L7n3jFb9.js
src/lhp/webapp/static/assets/InitProjectPage-4hNPPFjS.js
src/lhp/webapp/static/assets/MonacoEditorWrapper-Dn97cHk3.js
src/lhp/webapp/static/assets/OptionalTextField-nezRxV8T.js
src/lhp/webapp/static/assets/ParameterValueInput-B5KinVHR.js
src/lhp/webapp/static/assets/PipelineDagView-DTgHw6Fn.js
src/lhp/webapp/static/assets/PipelineFilterOptions-RqkjlM1O.js
src/lhp/webapp/static/assets/ProjectMapView-DBwV3PEa.js
src/lhp/webapp/static/assets/QuickOpenDialog-DqM0N3IJ.js
src/lhp/webapp/static/assets/RunHistoryView-DSEESrPz.js
src/lhp/webapp/static/assets/RunStreamView-b0itN28j.js
src/lhp/webapp/static/assets/StringListEditor-Cn8Q6uad.js
src/lhp/webapp/static/assets/TemplateBuilder-BA_B5-MC.js
src/lhp/webapp/static/assets/TemplateInvocationParams-C4_vZ0kJ.js
src/lhp/webapp/static/assets/TemplatePreview-BKl8A8ML.js
src/lhp/webapp/static/assets/TemplatePreviewGraph-BEfZ-sod.js
src/lhp/webapp/static/assets/TemplateResources-C-H2y3NC.js
src/lhp/webapp/static/assets/TemplateUseActions-DVIq2_ga.js
src/lhp/webapp/static/assets/browser-3KD14yjt.js
src/lhp/webapp/static/assets/button-BHcljLTc.js
src/lhp/webapp/static/assets/check-BqlIouHy.js
src/lhp/webapp/static/assets/chevron-down-CZfQecrB.js
src/lhp/webapp/static/assets/chevron-right-B6bC4fsj.js
src/lhp/webapp/static/assets/circle-x-BqA9GvZx.js
src/lhp/webapp/static/assets/client-CwGpWOCB.js
src/lhp/webapp/static/assets/codicon-ngg6Pgfi.ttf
src/lhp/webapp/static/assets/command-QQrres4q.js
src/lhp/webapp/static/assets/createLucideIcon-oYpdczSh.js
src/lhp/webapp/static/assets/designerGraph-CRFOmsTV.js
src/lhp/webapp/static/assets/dist-Ayd32CUL.js
src/lhp/webapp/static/assets/dist-Bsmj0pQS.js
src/lhp/webapp/static/assets/editor.worker-tytyn86m.js
src/lhp/webapp/static/assets/editorCommands-BzgCCo3i.js
src/lhp/webapp/static/assets/elk-worker.min-DX7bbvCB.js
src/lhp/webapp/static/assets/elkjs-w3JRw_We.js
src/lhp/webapp/static/assets/errors-DD94ok_U.js
src/lhp/webapp/static/assets/es2015-DgaTXviq.js
src/lhp/webapp/static/assets/field-help-BX7HJRzz.js
src/lhp/webapp/static/assets/files-D2FXRPQi.js
src/lhp/webapp/static/assets/flowgroup-doc-D1AdFOTW.js
src/lhp/webapp/static/assets/flowgroups-BReym-wu.js
src/lhp/webapp/static/assets/history-Cj5LEvIL.js
src/lhp/webapp/static/assets/index-BiM85PrE.js
src/lhp/webapp/static/assets/index-DlSaamuV.css
src/lhp/webapp/static/assets/info-UseF9OiL.js
src/lhp/webapp/static/assets/inter-cyrillic-ext-wght-normal-BOeWTOD4.woff2
src/lhp/webapp/static/assets/inter-cyrillic-wght-normal-DqGufNeO.woff2
src/lhp/webapp/static/assets/inter-greek-ext-wght-normal-DlzME5K_.woff2
src/lhp/webapp/static/assets/inter-greek-wght-normal-CkhJZR-_.woff2
src/lhp/webapp/static/assets/inter-latin-ext-wght-normal-DO1Apj_S.woff2
src/lhp/webapp/static/assets/inter-latin-wght-normal-Dx4kXJAl.woff2
src/lhp/webapp/static/assets/inter-vietnamese-wght-normal-CBcvBZtf.woff2
src/lhp/webapp/static/assets/jetbrains-mono-cyrillic-wght-normal-D73BlboJ.woff2
src/lhp/webapp/static/assets/jetbrains-mono-greek-wght-normal-Bw9x6K1M.woff2
src/lhp/webapp/static/assets/jetbrains-mono-latin-ext-wght-normal-DBQx-q_a.woff2
src/lhp/webapp/static/assets/jetbrains-mono-latin-wght-normal-B9CIFXIH.woff2
src/lhp/webapp/static/assets/jetbrains-mono-vietnamese-wght-normal-Bt-aOZkq.woff2
src/lhp/webapp/static/assets/json.worker-Oa9UrkKE.js
src/lhp/webapp/static/assets/kindStyles-B5TyoX7F.js
src/lhp/webapp/static/assets/label-CCTv8zjz.js
src/lhp/webapp/static/assets/layoutStore-AxXMUT2Y.js
src/lhp/webapp/static/assets/loader-circle-DZnEN64O.js
src/lhp/webapp/static/assets/monaco-editor-Br_kD0ds.css
src/lhp/webapp/static/assets/monaco-editor-Dk8lHBHy.js
src/lhp/webapp/static/assets/monaco-setup-C8mBGtWX.js
src/lhp/webapp/static/assets/monaco-yaml-B1UNAIQv.js
src/lhp/webapp/static/assets/popover-DNYiPIOz.js
src/lhp/webapp/static/assets/react-flow-DVKIB-Ki.js
src/lhp/webapp/static/assets/react-vendor-CgUSHstK.js
src/lhp/webapp/static/assets/rolldown-runtime-aKtaBQYM.js
src/lhp/webapp/static/assets/runStore-BUyP13fW.js
src/lhp/webapp/static/assets/schemas-Gyl5wdTh.js
src/lhp/webapp/static/assets/select-BruvFISM.js
src/lhp/webapp/static/assets/square-B2WzmutO.js
src/lhp/webapp/static/assets/telemetry-BCrE7a9D.js
src/lhp/webapp/static/assets/telemetry-bindings-DmWMBVgl.js
src/lhp/webapp/static/assets/template-authoring-B3mvs92b.js
src/lhp/webapp/static/assets/template-document-Dz_QYagN.js
src/lhp/webapp/static/assets/textarea-BOPi6oSK.js
src/lhp/webapp/static/assets/triangle-alert-Dzo4723e.js
src/lhp/webapp/static/assets/uiStore-Bi76B8sL.js
src/lhp/webapp/static/assets/useElkLayout-CcMRmxJi.js
src/lhp/webapp/static/assets/useEnvironments-BRJ_jquj.js
src/lhp/webapp/static/assets/useEventStream-DIB8CXNs.js
src/lhp/webapp/static/assets/useMapEnrichment-CNGwxHRU.js
src/lhp/webapp/static/assets/useTemplateAuthoring-C8kaCK-6.js
src/lhp/webapp/static/assets/wand-sparkles-Cwatw9Hm.js
src/lhp/webapp/static/assets/workflow-BNT86crL.js
src/lhp/webapp/static/assets/workspaceStore-D-McfpIW.js
src/lhp/webapp/static/assets/yaml.worker-CB8yMYQD.js
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_blueprint_discoverer.py
tests/test_blueprint_expander.py
tests/test_blueprint_flowgroup_discoverer.py
tests/test_blueprint_orchestrator.py
tests/test_blueprint_parser.py
tests/test_blueprint_use_syntax.py
tests/test_blueprint_validate.py
tests/test_blueprint_yaml_parser_b1.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_simplified.py
tests/test_bundle_preflight.py
tests/test_cdc_fanin.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_job_config.py
tests/test_cli_error_boundary.py
tests/test_cli_include_tests_flag.py
tests/test_cli_main_coverage.py
tests/test_cloudfiles_options.py
tests/test_code_generator.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_configuration_preview.py
tests/test_custom_datasource_generator.py
tests/test_dlt_cdc_validators_extended.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_loader.py
tests/test_f_string_compatibility.py
tests/test_fakes_picklable.py
tests/test_field_help_catalog.py
tests/test_file_substitution.py
tests/test_flowgroup_context_pickle.py
tests/test_flowgroup_discoverer.py
tests/test_flowgroup_outcome_pickle.py
tests/test_flowgroup_processor_include_tests.py
tests/test_flowgroup_processor_validation.py
tests/test_flowgroup_schema_parity.py
tests/test_foreachbatch_sink_generator.py
tests/test_foreachbatch_sink_model.py
tests/test_foreachbatch_sink_validation.py
tests/test_generate_command_parallel.py
tests/test_generate_command_parallel_failure_modes.py
tests/test_generate_perf_propagation.py
tests/test_generate_worker_log_leak.py
tests/test_import_manager.py
tests/test_integration.py
tests/test_integration_e2e.py
tests/test_job_name_validator.py
tests/test_kafka_load_generator.py
tests/test_kafka_validator.py
tests/test_lhperror_rendering.py
tests/test_load_generators.py
tests/test_load_operational_metadata.py
tests/test_local_variables.py
tests/test_max_workers_wiring_e2e.py
tests/test_metadata_column_validation.py
tests/test_models.py
tests/test_namespace_normalizer.py
tests/test_operational_metadata_selection.py
tests/test_orchestrator.py
tests/test_orchestrator_bundle_integration.py
tests/test_orchestrator_include_tests.py
tests/test_packaging.py
tests/test_persistent_parse_cache.py
tests/test_pipeline_config_loader.py
tests/test_pipeline_delta_serialization.py
tests/test_pipeline_executor.py
tests/test_pipeline_field_functionality.py
tests/test_pipeline_field_output_structure.py
tests/test_preset_manager.py
tests/test_preset_template_combination.py
tests/test_project_config_loader_extended.py
tests/test_project_schema_parity.py
tests/test_python_load_substitution.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_enforcement_deprecation.py
tests/test_schema_transform_file_support.py
tests/test_schema_transform_parser.py
tests/test_schema_transform_perf.py
tests/test_secret_code_generator.py
tests/test_secret_execution.py
tests/test_secret_validator.py
tests/test_secret_validator_extended.py
tests/test_sink_action_validation.py
tests/test_sink_generators.py
tests/test_sink_model_validation.py
tests/test_sql_transform_improvement.py
tests/test_streaming_table_source_function.py
tests/test_substitution.py
tests/test_substitution_type_conversion.py
tests/test_substitution_warnings.py
tests/test_telemetry_guard.py
tests/test_template_engine.py
tests/test_template_loaders.py
tests/test_template_smart_detection.py
tests/test_template_type_conversion.py
tests/test_test_validation.py
tests/test_transform_generators.py
tests/test_transform_operational_metadata.py
tests/test_transform_validator_extended.py
tests/test_unknown_field_validation.py
tests/test_validate_command_parallel.py
tests/test_validate_lhp_error_ipc.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_job_name_inheritance.py