LICENSE
MANIFEST.in
README.md
pyproject.toml
cli/__init__.py
cli/contract_test.py
cli/generate_dags.py
cli/infra_checks.py
cli/manifest_doctor.py
cli/manifest_lint.py
cli/manifest_schema.py
cli/pipeline_runs.py
cli/scaffold_integration.py
cli/show_lineage.py
dag_builder/__init__.py
dag_builder/builder.py
dag_builder/dag_builder_core.py
dag_builder/dependency_resolver.py
dag_builder/manifest_loader.py
dag_builder/task_factory.py
dlt_pipelines/__init__.py
dlt_pipelines/mongodb_runtime/__init__.py
dlt_pipelines/mongodb_runtime/mongodb/__init__.py
dlt_pipelines/mongodb_runtime/mongodb/helpers.py
dlt_utils/__init__.py
dlt_utils/airflow_dlt_runner.py
dlt_utils/airflow_variables.py
dlt_utils/clickhouse_helpers.py
dlt_utils/kafka_config.py
dlt_utils/manifest_runner.py
dlt_utils/naming.py
dlt_utils/oracle_serialization.py
dlt_utils/vault_env.py
dlt_utils/adapters/__init__.py
dlt_utils/adapters/http/__init__.py
dlt_utils/adapters/http/requests_client.py
dlt_utils/adapters/kafka/__init__.py
dlt_utils/adapters/kafka/base.py
dlt_utils/adapters/kafka/kafka_python.py
dlt_utils/adapters/kafka/types.py
dlt_utils/adapters/secrets/__init__.py
dlt_utils/adapters/secrets/backends.py
dlt_utils/adapters/secrets/connections.py
dlt_utils/adapters/secrets/types.py
dlt_utils/contracts/__init__.py
dlt_utils/contracts/contract_testing.py
dlt_utils/contracts/payload_contract.py
dlt_utils/core/__init__.py
dlt_utils/core/context.py
dlt_utils/core/error_taxonomy.py
dlt_utils/core/hooks.py
dlt_utils/core/infra_checks.py
dlt_utils/core/manifest_io.py
dlt_utils/core/manifest_overrides.py
dlt_utils/core/manifest_schema.py
dlt_utils/core/manifest_validation.py
dlt_utils/core/online_checks.py
dlt_utils/core/plan_output.py
dlt_utils/core/redaction.py
dlt_utils/core/registry.py
dlt_utils/core/run_modes.py
dlt_utils/core/run_orchestrator.py
dlt_utils/core/run_plan.py
dlt_utils/core/run_result.py
dlt_utils/core/services.py
dlt_utils/hooks/__init__.py
dlt_utils/hooks/audit_run.py
dlt_utils/hooks/basic_logging.py
dlt_utils/hooks/env_summary.py
dlt_utils/hooks/explain_config.py
dlt_utils/hooks/replace_policy.py
dlt_utils/patterns/__init__.py
dlt_utils/patterns/kafka_async_job.py
dlt_utils/patterns/polling.py
dlt_utils/plugins/__init__.py
dlt_utils/plugins/examples/__init__.py
dlt_utils/plugins/examples/hooks_plugin.py
dlt_utils/plugins/examples/runners_plugin.py
dlt_utils/runners/__init__.py
dlt_utils/runners/base.py
dlt_utils/runners/bins.py
dlt_utils/runners/common.py
dlt_utils/runners/mongodb.py
dlt_utils/runners/oracle_custom_sql.py
dlt_utils/runners/source_config.py
dlt_utils/runners/sql_database.py
dltaf/__init__.py
dltaf.egg-info/PKG-INFO
dltaf.egg-info/SOURCES.txt
dltaf.egg-info/dependency_links.txt
dltaf.egg-info/entry_points.txt
dltaf.egg-info/requires.txt
dltaf.egg-info/top_level.txt
dltaf/adapters/__init__.py
dltaf/adapters/http/__init__.py
dltaf/adapters/http/requests_client.py
dltaf/adapters/kafka/__init__.py
dltaf/adapters/kafka/kafka_python_waiter.py
dltaf/adapters/secrets/__init__.py
dltaf/adapters/secrets/composite_provider.py
dltaf/app/__init__.py
dltaf/app/context.py
dltaf/app/deprecation.py
dltaf/app/runtime.py
dltaf/app/services.py
dltaf/cli/__init__.py
dltaf/cli/__main__.py
dltaf/cli/main.py
dltaf/cli/parser.py
dltaf/commands/__init__.py
dltaf/commands/base.py
dltaf/commands/registry.py
dltaf/commands/contracts/__init__.py
dltaf/commands/contracts/test.py
dltaf/commands/dags/__init__.py
dltaf/commands/dags/generate.py
dltaf/commands/dev/__init__.py
dltaf/commands/dev/build_package.py
dltaf/commands/dev/export_consumer_skeleton.py
dltaf/commands/dev/export_cutover_dry_run.py
dltaf/commands/dev/export_cutover_handoff.py
dltaf/commands/dev/export_framework_skeleton.py
dltaf/commands/dev/export_import_rehearsal.py
dltaf/commands/dev/export_repo_split_plan.py
dltaf/commands/dev/publish_package.py
dltaf/commands/dev/repo_split_inventory.py
dltaf/commands/dev/run_import_rehearsal.py
dltaf/commands/dev/smoke_installed_package.py
dltaf/commands/docs/__init__.py
dltaf/commands/docs/generate_cli_reference.py
dltaf/commands/docs/update_dev_metrics.py
dltaf/commands/infra_checks/__init__.py
dltaf/commands/infra_checks/list.py
dltaf/commands/infra_checks/run.py
dltaf/commands/lineage/__init__.py
dltaf/commands/lineage/show.py
dltaf/commands/manifest/__init__.py
dltaf/commands/manifest/doctor.py
dltaf/commands/manifest/lint.py
dltaf/commands/manifest/run.py
dltaf/commands/manifest/schema.py
dltaf/commands/runs/__init__.py
dltaf/commands/runs/list.py
dltaf/commands/scaffold/__init__.py
dltaf/commands/scaffold/integration.py
dltaf/examples/__init__.py
dltaf/examples/manifests/__init__.py
dltaf/examples/manifests/smoke_mongodb.yaml
dltaf/examples/manifests/smoke_mongodb_catalog.yaml
dltaf/examples/manifests/smoke_oracle_custom_sql.yaml
dltaf/examples/manifests/smoke_sql_database_catalog.yaml
dltaf/examples/manifests/smoke_sqldb_catalog.yaml
dltaf/examples/manifests/smoke_sqldb_query.yaml
dltaf/examples/sql/__init__.py
dltaf/examples/sql/oracle_smoke_query.sql
dltaf/extensions/__init__.py
dltaf/extensions/base/__init__.py
dltaf/extensions/base/common.py
dltaf/extensions/base/plugin_loader.py
dltaf/extensions/base/registry.py
dltaf/extensions/hooks/__init__.py
dltaf/extensions/hooks/builtins.py
dltaf/extensions/hooks/pipeline.py
dltaf/extensions/hooks/plugin_loader.py
dltaf/extensions/hooks/protocol.py
dltaf/extensions/hooks/registry.py
dltaf/extensions/infra_checks/__init__.py
dltaf/extensions/infra_checks/builtins.py
dltaf/extensions/infra_checks/plugin_loader.py
dltaf/extensions/infra_checks/protocol.py
dltaf/extensions/infra_checks/registry.py
dltaf/extensions/runners/__init__.py
dltaf/extensions/runners/builtins.py
dltaf/extensions/runners/plugin_loader.py
dltaf/extensions/runners/protocol.py
dltaf/extensions/runners/registry.py
dltaf/integrations/__init__.py
dltaf/integrations/mongodb/__init__.py
dltaf/integrations/mongodb/config.py
dltaf/integrations/mongodb/runner.py
dltaf/integrations/mongodb/workflow.py
dltaf/integrations/oracle_custom_sql/__init__.py
dltaf/integrations/oracle_custom_sql/config.py
dltaf/integrations/oracle_custom_sql/runner.py
dltaf/integrations/oracle_custom_sql/workflow.py
dltaf/integrations/sql_database/__init__.py
dltaf/integrations/sql_database/config.py
dltaf/integrations/sql_database/runner.py
dltaf/integrations/sql_database/workflow.py
dltaf/integrations/sqldb/__init__.py
dltaf/integrations/sqldb/config.py
dltaf/integrations/sqldb/layout.py
dltaf/integrations/sqldb/normalizer.py
dltaf/integrations/sqldb/runner.py
dltaf/integrations/sqldb/workflow.py
dltaf/integrations/sqldb/dialects/__init__.py
dltaf/integrations/sqldb/dialects/base.py
dltaf/integrations/sqldb/dialects/generic.py
dltaf/integrations/sqldb/dialects/oracle.py
dltaf/integrations/sqldb/factories/__init__.py
dltaf/integrations/sqldb/factories/resources.py
dltaf/integrations/sqldb/factories/source_factory.py
dltaf/integrations/sqldb/modes/__init__.py
dltaf/integrations/sqldb/modes/base.py
dltaf/integrations/sqldb/modes/catalog.py
dltaf/integrations/sqldb/modes/query.py
dltaf/ports/__init__.py
dltaf/ports/http.py
dltaf/ports/kafka.py
dltaf/ports/secrets.py
dltaf/services/__init__.py
dltaf/services/contracts/__init__.py
dltaf/services/contracts/testing.py
dltaf/services/dags/__init__.py
dltaf/services/dags/generation.py
dltaf/services/dev/__init__.py
dltaf/services/dev/handoff.py
dltaf/services/dev/package_artifacts.py
dltaf/services/dev/rehearsal.py
dltaf/services/dev/repo_split.py
dltaf/services/docs/__init__.py
dltaf/services/docs/generate_cli_reference_service.py
dltaf/services/docs/update_dev_metrics_service.py
dltaf/services/execution/__init__.py
dltaf/services/execution/audit_service.py
dltaf/services/execution/context_builder.py
dltaf/services/execution/environment.py
dltaf/services/execution/error_taxonomy.py
dltaf/services/execution/executor.py
dltaf/services/execution/online_checks_service.py
dltaf/services/execution/planner.py
dltaf/services/execution/redaction_service.py
dltaf/services/execution/request.py
dltaf/services/execution/redaction/__init__.py
dltaf/services/execution/redaction/objects.py
dltaf/services/execution/redaction/policy.py
dltaf/services/execution/redaction/safe.py
dltaf/services/execution/redaction/text.py
dltaf/services/infra_checks/__init__.py
dltaf/services/infra_checks/catalog.py
dltaf/services/infra_checks/common.py
dltaf/services/infra_checks/runner.py
dltaf/services/lineage/__init__.py
dltaf/services/lineage/reporting.py
dltaf/services/manifests/__init__.py
dltaf/services/manifests/lint.py
dltaf/services/manifests/loader.py
dltaf/services/manifests/overrides.py
dltaf/services/manifests/resolver.py
dltaf/services/manifests/validator.py
dltaf/services/manifests/doctor/__init__.py
dltaf/services/manifests/doctor/analysis.py
dltaf/services/manifests/doctor/discovery.py
dltaf/services/manifests/doctor/fixes.py
dltaf/services/manifests/doctor/models.py
dltaf/services/manifests/doctor/service.py
dltaf/services/manifests/doctor/templates.py
dltaf/services/manifests/schema/__init__.py
dltaf/services/manifests/schema/base.py
dltaf/services/manifests/schema/common.py
dltaf/services/manifests/schema/manifest.py
dltaf/services/manifests/schema/service.py
dltaf/services/manifests/schema/sources.py
dltaf/services/runs/__init__.py
dltaf/services/runs/audit_listing.py
dltaf/services/scaffold/__init__.py
dltaf/services/scaffold/models.py
dltaf/services/scaffold/naming.py
dltaf/services/scaffold/pyproject.py
dltaf/services/scaffold/service.py
dltaf/services/scaffold/templates.py
lineage/__init__.py
lineage/dependency_graph.py
lineage/manifest_dependency_resolver.py
tests/test_dltaf_cli_smoke.py
tests/test_mongodb_public_runtime.py
tests/test_packaging_profiles.py
tests/test_public_examples_and_docs.py
tests/test_stage46_sqldb_foundation.py
tests/test_stage47_sqldb_catalog_runtime.py
tests/test_stage48_sqldb_query_runtime.py
tests/test_stage49_sqldb_alias_cleanup.py