Skip to main content

Engel-style semantic layer compiler for BigQuery

Project description

engel-semantic-layer

Engel-style semantic layer as a Python package.

This package lets users define metrics/modules in YAML (same shape as Engel's code reference) and compile executable BigQuery SQL for a metric query request.

Scope

  • YAML loading from:
    • one-module-per-file (module: root), or
    • single-file semantic layer (semantic_layer.modules + semantic_layer.cross_module_metrics)
  • Metric types:
    • sum
    • count
    • ratio
    • count-distinct
    • custom-value
    • custom-ratio
    • derived-ratio (cross-module, metric-on-metric, join_on: time)
  • Metric filters + query-time filters
  • Metric slices (slice_name) for base metrics
  • Time grain support: none, daily, weekly, monthly, quarterly, yearly
  • Breakdowns with dimension access checks
  • Join path traversal across modules
  • BigQuery SQL output

Changelog

See CHANGELOG.md for release notes.

Installation

Install from a private GitHub release wheel asset:

pip install \
  "https://github.com/<owner>/engel-semantic-layer/releases/download/v0.2.0/engel_semantic_layer-0.2.0-py3-none-any.whl"

For private repos, use authenticated download (tokened URL or API download flow).

Install from source for local development:

pip install -e .

Example

from engel_semantic_layer import QueryFilter, QueryRequest, SemanticLayer

layer = SemanticLayer.from_path("examples/model")

request = QueryRequest(
    from_date="2026-01-01T00:00:00Z",
    to_date="2026-01-31T23:59:59Z",
    time_grain="daily",
    breakdown_dimension_ids=["user_email"],
    filters=[
        QueryFilter(
            dimension_id="user_email",
            filter_values=["demo-user@example.com"],
        )
    ],
)

sql = layer.compile_sql(metric_id="metric_event_count", request=request)
print(sql)

YAML shape

You can use either:

  • one-module-per-file (module: root), or
  • a single semantic_layer.yml with modules and cross_module_metrics.
module:
  schema: "analytics"
  table: "records"
  identifier: "records"
  dimensions:
    - column: "country"
      type: "country"
  metrics:
    - identifier: "record_volume"
      name: "Record volume"
      ai_context:
        synonyms:
          - "booked value"
          - "record amount"
      calculation: "sum"
      time: "records.recorded_at"
      value: "records.amount"
      dimensions:
        - "this.*"

Cross-module derived ratio in single-file mode:

semantic_layer:
  modules:
    - identifier: "wide_metric_count_a"
      project: "demo-project-123456"
      schema: "analytics_wide"
      table: "wide_metric_count_a"
      metrics:
        - identifier: "metric_actual_primary"
          name: "Primary Metric, Actual"
          calculation: "sum"
          time: "wide_metric_count_a.fulfilled_at"
          value: "wide_metric_count_a.value_primary_amount"
          filters:
            - column: "settled_at"
              operator: "is-not"
              expression: "NULL"

    - identifier: "entity_snapshots"
      project: "demo-project-123456"
      schema: "analytics_marts"
      table: "entity_snapshots"
      metrics:
        - identifier: "metric_entities_active"
          name: "# Active Entities"
          calculation: "count-distinct"
          time: "entity_snapshots.date"
          distinct_on: "entity_snapshots.dim_entity_id"
          filters:
            - column: "is_live"
              operator: "is"
              expression: "true"

  cross_module_metrics:
    - identifier: "ratio_primary_per_entity"
      name: "Primary Metric per Active Entity"
      calculation: "derived-ratio"
      numerator_metric: "metric_actual_primary"
      denominator_metric: "metric_entities_active"
      join_on: "time"
      join_type: "inner" # optional: inner | left | full

API/OpenAPI field mapping (camelCase -> YAML snake_case):

  • sqlExpression -> sql_expression
  • numeratorSql -> numerator_sql
  • denominatorSql -> denominator_sql
  • numeratorMetricId -> numerator_metric
  • denominatorMetricId -> denominator_metric

Notes:

  • derived-ratio currently supports join_on: time.
  • join_type supports inner (default), left, and full (FULL OUTER JOIN).
  • query request must include timeGrain for cross-module metrics (timeGrain: none is not supported for cross-module derived ratios).
  • requested breakdowns must be available on both numerator and denominator metrics.

Publishing

Release asset workflow:

  • .github/workflows/release-assets.yml

What it does:

  • Runs tests
  • Builds wheel + sdist
  • Uploads artifacts to the GitHub release for v* tags
  • On manual dispatch, can attach to a specified tag or create a draft release

CLI

Validate your semantic model:

engel-semantic-layer validate --model-path examples/model --json

Compact summary output for CI logs:

engel-semantic-layer validate --model-path examples/model --json --summary-only

Validate that all metrics are compilable with synthetic dates (uses --time-grain monthly by default so cross-module metrics compile too):

engel-semantic-layer validate \
  --model-path examples/model \
  --json \
  --check-compilable

Override synthetic compile time grain when needed:

engel-semantic-layer validate \
  --model-path examples/semantic_layer.yml \
  --check-compilable \
  --time-grain weekly

Use period shortcuts instead of explicit from/to:

engel-semantic-layer validate \
  --model-path examples/model \
  --check-compilable \
  --period "last 12 months"

Write a full validation report artifact for CI (includes warning summary, compile failures, and per-metric validation statuses):

engel-semantic-layer validate \
  --model-path examples/model \
  --check-compilable \
  --report /tmp/semantic-validate-report.json

Fail on semantic warnings:

engel-semantic-layer validate \
  --model-path examples/model \
  --warnings-as-errors

Validate with strict column linting for all metrics:

engel-semantic-layer validate \
  --model-path examples/model \
  --json \
  --strict-column-lint \
  --column-registry /tmp/registry.json

List metrics:

engel-semantic-layer metrics --model-path examples/model

Machine-readable list + filters:

engel-semantic-layer metrics \
  --model-path examples/model \
  --format json \
  --module fact_records \
  --calculation sum

Inspect module join graph:

engel-semantic-layer joins --model-path examples/model --format json

Compile SQL from a metric + request payload:

engel-semantic-layer compile \
  --model-path examples/model \
  --metric-id metric_event_count \
  --request /tmp/request.json \
  --format sql

Compile a cross-module derived ratio from single-file semantic layer:

engel-semantic-layer compile \
  --model-path examples/semantic_layer.yml \
  --metric-id ratio_primary_per_entity \
  --request /tmp/request.json \
  --period "last 12 months" \
  --format sql

Get compiler explain output (resolved metadata + source files):

engel-semantic-layer compile \
  --model-path examples/model \
  --metric-id metric_event_count \
  --request /tmp/request.json \
  --format explain

Validate request compatibility without returning SQL:

engel-semantic-layer compile \
  --model-path examples/model \
  --metric-id metric_event_count \
  --request /tmp/request.json \
  --dry-run-validate

Use period shortcuts in compile:

engel-semantic-layer compile \
  --model-path examples/model \
  --metric-id metric_event_distinct_count \
  --request /tmp/request.json \
  --period "Q1 2025"

Supported period formats:

  • last x years
  • last x months
  • last x quarters
  • last x days
  • current year (YTD)
  • current month (MTD)
  • QX YYYY (e.g. Q2 2025)
  • YYYY (e.g. 2025)
  • MM-YYYY (e.g. 02-2025)

Time comparison options in request payload (timeComparison):

  • Percentage comparisons: YoY, MoM
  • Comparison values: Last Year, Last Month
  • Daily-only percentage comparison: YoY (Match Weekday)

YoY (Match Weekday) requires timeGrain: daily and compares to 364 days prior. With timeGrain: none, comparisons are done as full-window totals (e.g. YTD vs last YTD).

Target comparison option in request payload:

  • targetSeries (e.g. budget_current, stretch_target)

Period handling options in request payload:

  • excludeOpenPeriod (true|false)
  • excludeToday (true|false)

When excludeOpenPeriod is true, the compiler excludes the currently open period bucket for the selected timeGrain (e.g. current month for monthly, current day for daily).

When excludeToday is true, the compiler clips toDate by one day before other period logic.

Cumulative options in request payload:

  • cumulativeMode: mtd, ytd, rolling_days
  • rollingDays: positive integer (required only for rolling_days)

Validation rules:

  • mtd requires timeGrain: daily
  • rolling_days requires timeGrain: daily
  • ytd works with daily/weekly/monthly/quarterly/yearly grains
  • cumulative modes require a time grain (not none)

Output columns for cumulative mode:

  • metric_base (original bucket metric)
  • metric (cumulative metric)
  • if targetSeries is set: target_value_base + cumulative target_value

When targetSeries is provided, the compiler joins aggregated targets from demo-project-123456.analytics_prod.fct_targets_monthly by metric identifier, selected date range, and breakdown dimensions (if any), and returns:

  • target_value
  • target_comparison_percentage

Target source can be overridden in CLI with:

  • --target-project
  • --target-schema
  • --target-table

With --strict-column-lint, target columns used for series/metric/time/value, breakdowns, and dimension filters are validated against the column registry.

End-to-end request example (comparison + target + cumulative + period clipping):

{
  "fromDate": "2026-01-01T00:00:00Z",
  "toDate": "2026-12-31T23:59:59Z",
  "timeGrain": "monthly",
  "timeComparison": "YoY",
  "targetSeries": "budget_current",
  "cumulativeMode": "ytd",
  "excludeOpenPeriod": true,
  "excludeToday": true,
  "breakdownDimensionIds": ["segment_group"],
  "filters": [
    {
      "dimensionId": "segment_group",
      "filterValues": ["SegmentA"]
    }
  ]
}

You can also pipe request JSON through stdin:

echo '{"fromDate":"2026-01-01T00:00:00Z","toDate":"2026-01-31T23:59:59Z"}' | \
  engel-semantic-layer compile \
    --model-path examples/model \
    --metric-id metric_event_distinct_count \
    --request -

Compile with strict column linting:

engel-semantic-layer compile \
  --model-path examples/model \
  --metric-id metric_actual_secondary \
  --request /tmp/request.json \
  --strict-column-lint \
  --column-registry /tmp/registry.json

Optional strict column linting

You can enforce table+column existence checks during compile by providing a column registry.

from engel_semantic_layer import ColumnRegistry, QueryRequest, SemanticLayer

registry = ColumnRegistry.from_dict(
    {
        "analytics_wide": {
            "wide_metric_count_a": ["recorded_at", "fulfilled_at", "value_secondary_amount", "status"]
        }
    }
)

layer = SemanticLayer.from_path(
    "examples/model",
    strict_column_lint=True,
    column_registry=registry,
)

sql = layer.compile_sql(
    "metric_actual_secondary",
    QueryRequest(from_date="2026-01-01T00:00:00Z", to_date="2026-01-31T23:59:59Z"),
)

You can also construct the registry from INFORMATION_SCHEMA.COLUMNS rows using ColumnRegistry.from_information_schema_rows(...).

CLI helper:

engel-semantic-layer registry from-information-schema \
  --input /tmp/information_schema_rows.json \
  --output /tmp/registry.json

Input supports both:

  • JSON array ([ {...}, {...} ])
  • JSONL (one JSON object per line)

Testing

The test suite includes SQL snapshot tests for representative metrics. Run:

uv run --extra dev pytest -q

If SQL output intentionally changes, update snapshot files in tests/snapshots/.

CLI exit codes:

  • 0 success
  • 2 validation/parse/compile input error

For machine-readable failures, use --json-errors:

engel-semantic-layer --json-errors compile ...

Notes

  • This compiler focuses on BigQuery SQL generation.
  • Output aims to be Engel-like SQL, but this is an independent implementation.
  • Strict validation is enabled for basics: duplicate IDs, unsupported operators/calculations, invalid metric field combinations, and disallowed breakdown/filter dimensions.
  • Custom SQL metric expressions are normalized for BigQuery string literals (double-quoted strings are converted to single-quoted literals).
  • Custom SQL reference linting is enabled: dotted references in custom expressions are validated and unknown table references fail at compile time.
  • Query compilation guards against invalid breakdown requests (max 2 dimensions, no duplicates, no alias collisions).
  • Missing join-path errors are actionable and include metric + module context plus reference sources (which fields caused the dependency).

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

engel_semantic_layer-0.2.3.tar.gz (38.7 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

engel_semantic_layer-0.2.3-py3-none-any.whl (29.9 kB view details)

Uploaded Python 3

File details

Details for the file engel_semantic_layer-0.2.3.tar.gz.

File metadata

  • Download URL: engel_semantic_layer-0.2.3.tar.gz
  • Upload date:
  • Size: 38.7 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? Yes
  • Uploaded via: twine/6.1.0 CPython/3.13.7

File hashes

Hashes for engel_semantic_layer-0.2.3.tar.gz
Algorithm Hash digest
SHA256 1b0df4e00228aaeb15894f1dcffd69121af07a0b2574dab952c7d540b5e0383d
MD5 38617648faa189215270faab27008e2b
BLAKE2b-256 fbc25c3aa2e0b15d706824514a1b675030483c736213f707d8d5049f6e9e3398

See more details on using hashes here.

Provenance

The following attestation bundles were made for engel_semantic_layer-0.2.3.tar.gz:

Publisher: publish.yml on rasmusengelbrecht/engel-semantic-layer-public

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file engel_semantic_layer-0.2.3-py3-none-any.whl.

File metadata

File hashes

Hashes for engel_semantic_layer-0.2.3-py3-none-any.whl
Algorithm Hash digest
SHA256 7763f579fed214fb921e38dd59caad7f6dd02b870d458452e96e200b34f73c26
MD5 086f992fbe60ee8f921a18a75c2836bb
BLAKE2b-256 f899d5a12058939fab63f4c1f9974c12999f93c2169848daed2aaa94f764c3d6

See more details on using hashes here.

Provenance

The following attestation bundles were made for engel_semantic_layer-0.2.3-py3-none-any.whl:

Publisher: publish.yml on rasmusengelbrecht/engel-semantic-layer-public

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page