CML Spark schemas
Project description
Central Metrics Library Schemas (Python)
Supports CML Proforma version 2.0
A lightweight Python package providing validated schemas for the Central Metrics Library (CML) in (eventually) multiple formats.
Current focus: Apache Spark (pyspark.sql.types.StructType).
The Central Metrics Library (CML) defines a common structure for metrics and the metadata that describes them, so analytical teams can produce, discover, and reuse metrics consistently across the NHS. This package implements those schemas for use in data pipelines.
Why this exists
Today, metrics live in many places and many shapes—hard to find, easy to duplicate, and sometimes inconsistent. The CML aims to unify metric structures and metadata into a single, curated, service-managed library so analysts can source authoritative, consistently defined metrics, supported by appropriate security tagging and clear SME-owned definitions (purpose, methods, limitations, differences from similar measures). This repo hosts code-first schemas aligned to that aim.
Status: BETA
The CML—and therefore these schemas—are in beta while we pilot with analytical teams and iterate on feedback. Expect breaking changes as the specification evolves. Please adopt resilient coding practices and pin schema versions where appropriate.
What's in the box
Spark schemas for core CML entities (initial set):
METRIC_SCHEMA— the measured value(s) and identifiersDIMENSIONS_SCHEMA— base schema for dimensions used to slice metrics
Helper functions:
create_dimensions_schema(dimensions)— builds a full dimensions schema from a list of dimension column namesselect_from_schema(df, schema)— selects and reorders DataFrame columns to match a schemavalidate_schema(df, schema)— validates a DataFrame's column names and types against a schema
These mirror the "draft standardised schema" referenced in the CML materials and will track the official spec as it matures.
Coming soon:
metadataschema — descriptive info: purpose, methodology, caveats, lineage, etc.relationshipschema — links between metrics and other artefacts
Installation
pip install cml-schemas
Tip: Pin to a specific version (
cml-schemas==x.y.z) to protect your pipelines from breaking changes during beta.
Quick start (Spark)
Use a built-in schema
from cml_schemas import spark_schemas
# Create an empty, schema-correct DataFrame
empty_df = spark.createDataFrame([], schema=spark_schemas.METRIC_SCHEMA)
Build a dimensions schema dynamically
from cml_schemas import spark_schemas
dimensions = ["AgeGroup", "Region", "Ethnicity"]
schema = spark_schemas.create_dimensions_schema(dimensions)
empty_df = spark.createDataFrame([], schema=schema)
Validate a DataFrame against a schema
from cml_schemas import spark_schemas
# Raises TypeError with all mismatches listed if validation fails
spark_schemas.validate_schema(df, spark_schemas.METRIC_SCHEMA)
Use a typed metric schema
METRIC_SCHEMA stores metric_value as IntegerType by default. CML rules also permit float metric values — if your pipeline produces floats, use get_metric_schema() to get a schema with the correct type enforced:
from cml_schemas import spark_schemas
# metric_value as FloatType
float_schema = spark_schemas.get_metric_schema("float")
empty_df = spark.createDataFrame([], schema=float_schema)
All other fields are identical to METRIC_SCHEMA.
Select and reorder columns to match a schema
from cml_schemas import spark_schemas
# Selects only the columns defined in the schema, in schema order
df = spark_schemas.select_from_schema(df, spark_schemas.METRIC_SCHEMA)
Principles for usage
- Spec-first: Schemas track the CML Data Specification (draft during beta). When the official fields or formats change, this package revs a minor or major version, with changelog notes. We recommend locking to a specific version of this package to avoid breaking changes when the schema is updated.
- Build from tidy data where possible: Aim to produce metrics by first producing outputs in tidy-data format and converting from there to the CML spec. See the CML conversion helper functions.
- RAP: Aim to develop your pipelines in line with RAP (Reproducible Analytical Pipelines) principles — see the RAP Community of Practice website for guidance.
How this maps to the CML artefacts
- CML Proforma & Spec: Informs field names, types, nullability, and relationships for
metric,metadata,relationship,source,dimension. Producers can continue to complete the proforma as documentation while using these programmatic schemas in code. - Ownership & curation: This repo does not own business definitions; SMEs own and maintain metric definitions. We only provide the technical shapes to carry those definitions consistently.
- Discovery & serving: FDP National/Metadata Explore Hub will surface metrics/metadata to end users. This package helps you produce compliant data for that ecosystem.
Versioning
Note: package versions do not map to CML Proforma versions. See the top of this README for the currently supported proforma version, or CHANGELOG.md for the proforma version supported by each past release.
This package follows Semantic Versioning:
- Major (
x.0.0) — breaking changes to schema field names, types, or nullability (expect these during beta as the CML spec evolves) - Minor (
0.x.0) — new schemas or helper functions added in a backwards-compatible way - Patch (
0.0.x) — bug fixes and non-breaking internal changes
Pin to a specific version in your pipelines (cml-schemas==x.y.z) to protect yourself from breaking changes.
Contributing
We welcome issues and PRs, especially for:
- Gaps or mismatches vs the CML spec (with references)
- Additional runtime formats (e.g., JSON Schema, SQL DDL)
- Validation and test data generators
- Developer experience improvements
Setting up your environment
We recommend using GitHub Codespaces — this repo's devcontainer will automatically install pipx and poetry for you.
Once your Codespace is ready (or if you're working locally with pipx and poetry already installed):
# Install dependencies and create the virtual environment
poetry install
# Activate the environment
poetry shell
To run the tests:
pytest
Branching
Create a branch from main using a prefix that describes the type of change:
feature/your-branch-name— new functionalitypatch/your-branch-name— bug fixes or minor tweakschore/your-branch-name— non-functional changes (docs, config, CI)
Making changes
All changes must be made via a pull request on GitHub and require at least one approval before merging.
Publishing to PyPI
- Bump the version in
pyproject.tomlfollowing semver (see above) - Update CHANGELOG.md with the new version and a summary of changes
- Open a PR, get it approved, and merge to
main - On GitHub, create a new Release targeting
main, using the version number as the tag (e.g.v2.1.0) — this triggers the publish workflow automatically
One-time setup: the publish workflow requires a PyPI API token stored as a repository secret. If the release does not trigger the package to be published, contact an owner of the package on PyPI - a token scoped to the
cml-schemasproject may need to be created in PyPI and added in GitHub under Settings → Secrets and variables → Actions asPYPI_API_TOKEN.
Test PyPI
Want to do a test run first? Publish to Test PyPI manually:
poetry config repositories.test-pypi https://upload.pypi.org/legacy/
poetry config pypi-token.test-pypi <your-test-pypi-token>
poetry publish --build --repository test-pypi
Then, in a separate project to this one, verify the install from Test PyPI and make sure it's all working as you intended:
pip install --index-url https://test.pypi.org/simple/ --extra-index-url https://pypi.org/simple/ cml-schemas
License
MIT
Acknowledgements
This package is inspired by and aligned to the Central Metrics Library initiative, developed with analytical teams and Platform Modernisation to fit the developing FDP National platform.
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file cml_schemas-2.0.0.tar.gz.
File metadata
- Download URL: cml_schemas-2.0.0.tar.gz
- Upload date:
- Size: 7.1 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: poetry/2.3.3 CPython/3.12.3 Linux/6.17.0-1010-azure
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
c1862f02acb590fd00c8e00e8afd88fa7c30acc4c8d372256ad76e80b888cdf4
|
|
| MD5 |
2010d30aa573126a0730bca14b74e510
|
|
| BLAKE2b-256 |
3c4e64ff8aec90ea4a8bffb68eda4e79f74ef59b539fd8c6b000f701d5d0ec60
|
File details
Details for the file cml_schemas-2.0.0-py3-none-any.whl.
File metadata
- Download URL: cml_schemas-2.0.0-py3-none-any.whl
- Upload date:
- Size: 7.9 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via: poetry/2.3.3 CPython/3.12.3 Linux/6.17.0-1010-azure
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
39e2db5bb27a090fe4a1f04860254fb2f33cf80fb33fc301b10c02593d320152
|
|
| MD5 |
057522e33785046083c4e32f9d89e1b0
|
|
| BLAKE2b-256 |
ad33952b4563d071d9c12cdc8b8803d7cbb90fa0fd398c21d7139aee7029dfab
|