You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Update docs and READMEs for lakeflow_framework package paths.
Align operational metadata, templates, logging, config, validator, and test
docs with the packaged layout; extend the spelling wordlist; rephrase
historized to history-tracked in samples README.
Copy file name to clipboardExpand all lines: docs/source/feature_logging.rst
+4-4Lines changed: 4 additions & 4 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -18,7 +18,7 @@ You can optionally plug in a **custom logger** via a dedicated ``logger.json`` c
18
18
.. admonition:: Setting Precedence
19
19
:class: warning
20
20
21
-
* Framework code and extensions should use the shared logger helper ``pipeline_config.get_logger()`` rather than creating their own loggers.
21
+
* Framework code and extensions should use the shared logger helper ``get_logger()`` from ``lakeflow_framework.pipeline_config`` rather than creating their own loggers.
``utility.set_logger`` remains for backward compatibility and delegates to the framework default logger factory; new code should use ``pipeline_config.get_logger()``.
468
+
``lakeflow_framework.utility.set_logger`` remains for backward compatibility and delegates to the framework default logger factory; new code should use ``get_logger()`` from ``lakeflow_framework.pipeline_config``.
469
469
470
-
Custom loggers that support async flushing may require an explicit ``close()`` at the end of the pipeline. Consider a **post_init** hook under ``extensions/post_init/`` that calls ``close()`` on the primary logger when exposed.
470
+
Custom loggers that support async flushing may require an explicit ``close()`` at the end of the pipeline. Consider a **post-init** hook under ``src/init/post/`` (pipeline bundle) or ``src/local/init/post/`` (framework bundle) that calls ``close()`` on the primary logger when exposed.
Copy file name to clipboardExpand all lines: docs/source/feature_operational_metadata.rst
+1-1Lines changed: 1 addition & 1 deletion
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -29,7 +29,7 @@ Configuration
29
29
-------------
30
30
31
31
|**Scope: Global**
32
-
|In the Framework bundle, operational metadata columns are defined in JSON configuration files at Lakehouse layer level (e.g. bronze, silver, gold). The configuration files are locate at and must be named as follows: ``src/config/default/operational_metadata_<layer>.json``
32
+
|In the Framework bundle, operational metadata columns are defined in JSON configuration files at Lakehouse layer level (e.g. bronze, silver, gold). The configuration files are locate at and must be named as follows: ``src/lakeflow_framework/config/default/operational_metadata_<layer>.json``
Copy file name to clipboardExpand all lines: samples/README.md
+3-3Lines changed: 3 additions & 3 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -7,7 +7,7 @@ The Framework comes with extensive samples that demonstrate the use of the frame
7
7
|**`feature-samples`**| Demonstrates every framework feature in isolation using a single `{namespace}_feature` schema. The simplest entry point. |
8
8
|**`pattern-samples`**| End-to-end medallion architecture patterns (bronze → silver → gold) across multiple schemas. Includes multi-source streaming, stream-static joins, CDC from snapshot sources, and gold-layer materialized views. |
9
9
|**`yaml_sample`**| Demonstrates that data flow specs can be written in YAML format instead of JSON. Contains YAML equivalents of basic specs. |
10
-
|**`tpch_sample`**| The most comprehensive end-to-end reference, built on the TPC-H dataset in the UC samples catalog. Covers multi-source schema-on-read bronze, conformed/historized silver (SCD2 + SCD1 + append-only facts with DQ quarantine), and a governed gold star schema with surrogate keys, point-in-time joins, pre-aggregated MVs, and UC metric views. Uses template specs and a three-run incremental simulation. See its [README](tpch_sample/README.md). |
10
+
|**`tpch_sample`**| The most comprehensive end-to-end reference, built on the TPC-H dataset in the UC samples catalog. Covers multi-source schema-on-read bronze, conformed/history-tracked silver (SCD2 + SCD1 + append-only facts with DQ quarantine), and a governed gold star schema with surrogate keys, point-in-time joins, pre-aggregated MVs, and UC metric views. Uses template specs and a three-run incremental simulation. See its [README](tpch_sample/README.md). |
11
11
12
12
## Deploying the Samples
13
13
@@ -146,12 +146,12 @@ Parameters:
146
146
147
147
## TPC-H Sample
148
148
149
-
The TPC-H sample is the most comprehensive end-to-end example in the framework. Built on the TPC-H schema in the Databricks UC samples catalog, it turns a realistic, sample dataset into a fully streaming medallion data warehouse — from multi-source raw ingestion through conformed, historized silver to a governed gold star schema with value-add aggregations.
149
+
The TPC-H sample is the most comprehensive end-to-end example in the framework. Built on the TPC-H schema in the Databricks UC samples catalog, it turns a realistic, sample dataset into a fully streaming medallion data warehouse — from multi-source raw ingestion through conformed, history-tracked silver to a governed gold star schema with value-add aggregations.
150
150
151
151
It demonstrates a wide range of framework capabilities together, including:
152
152
153
153
***Schema-on-read bronze** that infers and evolves the schema, ingesting Parquet from eight simulated source systems via Auto Loader.
154
-
***Conformed, historized silver** with SCD2 dimensions, SCD1 reference data, append-only facts, and data-quality expectations with quarantine.
154
+
***Conformed, history-tracked silver** with SCD2 dimensions, SCD1 reference data, append-only facts, and data-quality expectations with quarantine.
155
155
***Governed gold star schema** with surrogate keys and point-in-time (as-of) joins, plus two metrics approaches side by side: pre-aggregated materialized views and UC metric views.
156
156
***Template specs** that collapse repetitive bronze and silver flows into reusable templates.
157
157
***A three-run incremental simulation** covering SCD changes, fact growth, a backdated out-of-order correction, and ongoing quarantine.
└── test_feature_samples_spec_builder.py # DataflowSpecBuilder on feature-samples
37
37
```
38
38
@@ -50,7 +50,7 @@ Configure in `pytest.ini`. CI runs: `-m "not integration and not spark"`.
50
50
51
51
1.**Use `pipeline_context`** — do not call `initialize_core()` inline in test modules.
52
52
2.**Prefer `tests/fixtures/`** — unit tests should not depend on `samples/` paths.
53
-
3.**Mirror `src/`** — `tests/unit/test_<module>.py` maps to `src/<module>.py`.
53
+
3.**Mirror the package** — `tests/unit/test_<module>.py` maps to `src/lakeflow_framework/<module>.py`; use `lakeflow_framework.*` imports (not compat shims).
54
54
4.**One concern per test** — name tests `test_<behavior>_when_<condition>`.
55
55
5.**No DLT mocks** — tests that need `@dp.table` belong in samples/E2E, not unit tests.
0 commit comments