Block a user
dab: add CLI --pipeline/--catalog flags for Databricks wheel execution
Complete.
- Added
--catalogoption tostack run(impliestarget=spark) - Added
_SparkContextclass withmake_databricks_loaderintegration stack run readmissions --catalog aco_dev…
dab: regenerate bundle/sql/ to match current pipeline code
dab: regenerate bundle/sql/ to match current pipeline code
Complete.
Regenerated all 208 SQL files via --dab-sql. Result: zero diff — SQL was already in sync with current pipeline code.
Note: cms_quality_measures/_error.txt is a known transpile…
dab: remove unused large cluster config from stack.toml
dab: remove unused large cluster config from stack.toml
Complete.
- Removed
[databricks.clusters.large]from stack.toml (i3.2xlarge, 4 workers — unused, no pipeline references it) - Regenerated databricks.yml — only
default_clusterremains
✅…
dab: filter Unity Catalog schemas to pipeline-produced only
dab: filter Unity Catalog schemas to pipeline-produced only
Complete.
- Added
Catalog.pipeline_schemas()— derives schemas from pipeline registry output names - Updated
_get_catalog_schemas()in DAB generator to usepipeline_schemas() - Result: 13…
dab: regenerate bundle/sql/ to match current pipeline code
Starting SQL regeneration. This takes ~4 minutes (transpiles all 228 expressions).
dab: filter Unity Catalog schemas to pipeline-produced only
Starting. Will add pipeline_schemas() to catalog.py and use it in the DAB generator.
dab: final validation — databricks bundle validate, tests, cleanup
dab: add databricks-bundles package and Python resource loader
dab: replace sql_task with python_wheel_task in JobsPlugin
dab: add CLI --pipeline/--catalog flags for Databricks wheel execution
dab: regenerate bundle/sql/ to match current pipeline code
dab: retain SQL transpilation as validation/audit tool only
dab: filter Unity Catalog schemas to pipeline-produced only
dab: remove unused large cluster config from stack.toml