add generated docs content: CLI, REST API, pipelines, DAG, package-lock

This commit is contained in:
kert
2026-03-12 20:03:30 -04:00
parent e07c8e76e9
commit 46488d1be8
56 changed files with 21308 additions and 0 deletions

View File

@@ -0,0 +1 @@
{"label": "CLI Reference", "position": 10}

View File

@@ -0,0 +1,21 @@
---
title: stack api serve
sidebar_position: 28
---
# `stack api serve`
```
Usage: stack api serve [OPTIONS]
Start the stack API server.
╭─ Options ────────────────────────────────────────────────────────────────────╮
│ --host TEXT Bind address. │
│ --port INTEGER Port number. │
│ --workers INTEGER Number of workers. │
│ --reload --no-reload Enable auto-reload. │
│ [default: no-reload] │
│ --help Show this message and exit. │
╰──────────────────────────────────────────────────────────────────────────────╯
```

19
docs/docs/cli/api.md Normal file
View File

@@ -0,0 +1,19 @@
---
title: stack api
sidebar_position: 27
---
# `stack api`
```
Usage: stack api [OPTIONS] COMMAND [ARGS]...
API server.
╭─ Options ────────────────────────────────────────────────────────────────────╮
│ --help Show this message and exit. │
╰──────────────────────────────────────────────────────────────────────────────╯
╭─ Commands ───────────────────────────────────────────────────────────────────╮
│ serve Start the stack API server. │
╰──────────────────────────────────────────────────────────────────────────────╯
```

View File

@@ -0,0 +1,19 @@
---
title: stack bib query
sidebar_position: 14
---
# `stack bib query`
```
Usage: stack bib query [OPTIONS] TERM
Search the bibliography store.
╭─ Arguments ──────────────────────────────────────────────────────────────────╮
│ * term TEXT Search term. [required] │
╰──────────────────────────────────────────────────────────────────────────────╯
╭─ Options ────────────────────────────────────────────────────────────────────╮
│ --help Show this message and exit. │
╰──────────────────────────────────────────────────────────────────────────────╯
```

17
docs/docs/cli/bib-sync.md Normal file
View File

@@ -0,0 +1,17 @@
---
title: stack bib sync
sidebar_position: 12
---
# `stack bib sync`
```
Usage: stack bib sync [OPTIONS]
Apply col: tags as DuckDB column comments.
╭─ Options ────────────────────────────────────────────────────────────────────╮
│ --dry-run Report without applying. │
│ --help Show this message and exit. │
╰──────────────────────────────────────────────────────────────────────────────╯
```

19
docs/docs/cli/bib-tag.md Normal file
View File

@@ -0,0 +1,19 @@
---
title: stack bib tag
sidebar_position: 13
---
# `stack bib tag`
```
Usage: stack bib tag [OPTIONS] [PATTERN]
List or search bibliography tags.
╭─ Arguments ──────────────────────────────────────────────────────────────────╮
│ pattern [PATTERN] Tag namespace or pattern to filter. │
╰──────────────────────────────────────────────────────────────────────────────╯
╭─ Options ────────────────────────────────────────────────────────────────────╮
│ --help Show this message and exit. │
╰──────────────────────────────────────────────────────────────────────────────╯
```

21
docs/docs/cli/bib.md Normal file
View File

@@ -0,0 +1,21 @@
---
title: stack bib
sidebar_position: 11
---
# `stack bib`
```
Usage: stack bib [OPTIONS] COMMAND [ARGS]...
Bibliography operations.
╭─ Options ────────────────────────────────────────────────────────────────────╮
│ --help Show this message and exit. │
╰──────────────────────────────────────────────────────────────────────────────╯
╭─ Commands ───────────────────────────────────────────────────────────────────╮
│ sync Apply col: tags as DuckDB column comments. │
│ tag List or search bibliography tags. │
│ query Search the bibliography store. │
╰──────────────────────────────────────────────────────────────────────────────╯
```

View File

@@ -0,0 +1,16 @@
---
title: stack db comment
sidebar_position: 21
---
# `stack db comment`
```
Usage: stack db comment [OPTIONS]
Apply column comments from bib metadata to DuckDB.
╭─ Options ────────────────────────────────────────────────────────────────────╮
│ --help Show this message and exit. │
╰──────────────────────────────────────────────────────────────────────────────╯
```

View File

@@ -0,0 +1,19 @@
---
title: stack db inspect
sidebar_position: 22
---
# `stack db inspect`
```
Usage: stack db inspect [OPTIONS] [TABLE]
Inspect DuckDB table schema and stats.
╭─ Arguments ──────────────────────────────────────────────────────────────────╮
│ table [TABLE] Table name (schema.table). │
╰──────────────────────────────────────────────────────────────────────────────╯
╭─ Options ────────────────────────────────────────────────────────────────────╮
│ --help Show this message and exit. │
╰──────────────────────────────────────────────────────────────────────────────╯
```

20
docs/docs/cli/db.md Normal file
View File

@@ -0,0 +1,20 @@
---
title: stack db
sidebar_position: 20
---
# `stack db`
```
Usage: stack db [OPTIONS] COMMAND [ARGS]...
DuckDB utilities.
╭─ Options ────────────────────────────────────────────────────────────────────╮
│ --help Show this message and exit. │
╰──────────────────────────────────────────────────────────────────────────────╯
╭─ Commands ───────────────────────────────────────────────────────────────────╮
│ comment Apply column comments from bib metadata to DuckDB. │
│ inspect Inspect DuckDB table schema and stats. │
╰──────────────────────────────────────────────────────────────────────────────╯
```

View File

@@ -0,0 +1,17 @@
---
title: stack docs build
sidebar_position: 24
---
# `stack docs build`
```
Usage: stack docs build [OPTIONS]
Generate documentation site.
╭─ Options ────────────────────────────────────────────────────────────────────╮
│ --skip-generate Skip content generation, only run Docusaurus build. │
│ --help Show this message and exit. │
╰──────────────────────────────────────────────────────────────────────────────╯
```

View File

@@ -0,0 +1,16 @@
---
title: stack docs generate
sidebar_position: 26
---
# `stack docs generate`
```
Usage: stack docs generate [OPTIONS]
Generate documentation content without building the site.
╭─ Options ────────────────────────────────────────────────────────────────────╮
│ --help Show this message and exit. │
╰──────────────────────────────────────────────────────────────────────────────╯
```

View File

@@ -0,0 +1,18 @@
---
title: stack docs serve
sidebar_position: 25
---
# `stack docs serve`
```
Usage: stack docs serve [OPTIONS]
Serve documentation locally with hot reload.
╭─ Options ────────────────────────────────────────────────────────────────────╮
│ --port INTEGER Port to serve on. [default: 3000] │
│ --skip-generate Skip content generation. │
│ --help Show this message and exit. │
╰──────────────────────────────────────────────────────────────────────────────╯
```

21
docs/docs/cli/docs.md Normal file
View File

@@ -0,0 +1,21 @@
---
title: stack docs
sidebar_position: 23
---
# `stack docs`
```
Usage: stack docs [OPTIONS] COMMAND [ARGS]...
Documentation generation.
╭─ Options ────────────────────────────────────────────────────────────────────╮
│ --help Show this message and exit. │
╰──────────────────────────────────────────────────────────────────────────────╯
╭─ Commands ───────────────────────────────────────────────────────────────────╮
│ build Generate documentation site. │
│ serve Serve documentation locally with hot reload. │
│ generate Generate documentation content without building the site. │
╰──────────────────────────────────────────────────────────────────────────────╯
```

View File

@@ -0,0 +1,17 @@
---
title: stack generate models
sidebar_position: 10
---
# `stack generate models`
```
Usage: stack generate models [OPTIONS]
Regenerate Pydantic table models from DuckDB schemas.
╭─ Options ────────────────────────────────────────────────────────────────────╮
│ --sync --no-sync Run bib sync before generating. [default: sync] │
│ --help Show this message and exit. │
╰──────────────────────────────────────────────────────────────────────────────╯
```

19
docs/docs/cli/generate.md Normal file
View File

@@ -0,0 +1,19 @@
---
title: stack generate
sidebar_position: 9
---
# `stack generate`
```
Usage: stack generate [OPTIONS] COMMAND [ARGS]...
Regenerate code artefacts.
╭─ Options ────────────────────────────────────────────────────────────────────╮
│ --help Show this message and exit. │
╰──────────────────────────────────────────────────────────────────────────────╯
╭─ Commands ───────────────────────────────────────────────────────────────────╮
│ models Regenerate Pydantic table models from DuckDB schemas. │
╰──────────────────────────────────────────────────────────────────────────────╯
```

16
docs/docs/cli/health.md Normal file
View File

@@ -0,0 +1,16 @@
---
title: stack health
sidebar_position: 4
---
# `stack health`
```
Usage: stack health [OPTIONS]
Run health checks on all platform services.
╭─ Options ────────────────────────────────────────────────────────────────────╮
│ --help Show this message and exit. │
╰──────────────────────────────────────────────────────────────────────────────╯
```

View File

@@ -0,0 +1,22 @@
---
title: stack lake deploy
sidebar_position: 16
---
# `stack lake deploy`
```
Usage: stack lake deploy [OPTIONS]
Create schemas and tables from SQLTable models.
╭─ Options ────────────────────────────────────────────────────────────────────╮
│ --target TEXT Target: iceberg (nessie/polaris) or databricks. │
│ [default: iceberg] │
│ --catalog-type TEXT Catalog type: nessie or polaris. │
│ [default: nessie] │
│ --schema TEXT Only deploy these schemas. │
│ --dry-run Report without creating. │
│ --help Show this message and exit. │
╰──────────────────────────────────────────────────────────────────────────────╯
```

View File

@@ -0,0 +1,20 @@
---
title: stack lake load
sidebar_position: 17
---
# `stack lake load`
```
Usage: stack lake load [OPTIONS]
Populate Iceberg tables with data from DuckDB.
╭─ Options ────────────────────────────────────────────────────────────────────╮
│ --catalog-type TEXT Catalog type: nessie or polaris. │
│ [default: nessie] │
│ --schema TEXT Only load these schemas. │
│ --mode TEXT Write mode: append or replace. [default: append] │
│ --help Show this message and exit. │
╰──────────────────────────────────────────────────────────────────────────────╯
```

View File

@@ -0,0 +1,17 @@
---
title: stack lake parity
sidebar_position: 19
---
# `stack lake parity`
```
Usage: stack lake parity [OPTIONS]
Compare pipeline outputs between DuckDB and Databricks.
╭─ Options ────────────────────────────────────────────────────────────────────╮
│ --schema TEXT Only check these schemas. │
│ --help Show this message and exit. │
╰──────────────────────────────────────────────────────────────────────────────╯
```

View File

@@ -0,0 +1,19 @@
---
title: stack lake validate
sidebar_position: 18
---
# `stack lake validate`
```
Usage: stack lake validate [OPTIONS]
Validate Iceberg tables match SQLTable model definitions.
╭─ Options ────────────────────────────────────────────────────────────────────╮
│ --catalog-type TEXT Catalog type: nessie or polaris. │
│ [default: nessie] │
│ --schema TEXT Only validate these schemas. │
│ --help Show this message and exit. │
╰──────────────────────────────────────────────────────────────────────────────╯
```

22
docs/docs/cli/lake.md Normal file
View File

@@ -0,0 +1,22 @@
---
title: stack lake
sidebar_position: 15
---
# `stack lake`
```
Usage: stack lake [OPTIONS] COMMAND [ARGS]...
Lakehouse schema and data.
╭─ Options ────────────────────────────────────────────────────────────────────╮
│ --help Show this message and exit. │
╰──────────────────────────────────────────────────────────────────────────────╯
╭─ Commands ───────────────────────────────────────────────────────────────────╮
│ deploy Create schemas and tables from SQLTable models. │
│ load Populate Iceberg tables with data from DuckDB. │
│ validate Validate Iceberg tables match SQLTable model definitions. │
│ parity Compare pipeline outputs between DuckDB and Databricks. │
╰──────────────────────────────────────────────────────────────────────────────╯
```

View File

@@ -0,0 +1,22 @@
---
title: stack load bcda
sidebar_position: 7
---
# `stack load bcda`
```
Usage: stack load bcda [OPTIONS]
Flatten BCDA FHIR exports and load into DuckDB.
Reads Patient/EOB/Coverage ndjson files, flattens them to Parquet,
and loads into the ``bcda`` schema.
╭─ Options ────────────────────────────────────────────────────────────────────╮
│ --ndjson-dir PATH Directory containing FHIR ndjson files. │
│ --database TEXT DuckDB database path (default: config). │
│ --skip-flatten Skip flattening, load existing Parquet. │
│ --help Show this message and exit. │
╰──────────────────────────────────────────────────────────────────────────────╯
```

View File

@@ -0,0 +1,23 @@
---
title: stack load cclf
sidebar_position: 6
---
# `stack load cclf`
```
Usage: stack load cclf [OPTIONS]
Ingest CCLF claim files into DuckDB.
Reads fixed-width CCLF files (plain or ZIP) from the given directory,
parses them into the ``cclf`` schema, then runs the 19-step CCLF
pipeline to produce ``input_layer`` tables.
╭─ Options ────────────────────────────────────────────────────────────────────╮
│ * --path PATH Directory containing CCLF files. [required] │
│ --database TEXT DuckDB database path (default: config). │
│ --no-pipeline Load raw tables only, skip CCLF pipeline. │
│ --help Show this message and exit. │
╰──────────────────────────────────────────────────────────────────────────────╯
```

View File

@@ -0,0 +1,20 @@
---
title: stack load seed
sidebar_position: 8
---
# `stack load seed`
```
Usage: stack load seed [OPTIONS]
Load seed/reference data (CSV, Excel, Parquet) into DuckDB.
╭─ Options ────────────────────────────────────────────────────────────────────╮
│ --seed-dir PATH Directory containing seed files. │
│ --database TEXT DuckDB database path (default: config). │
│ --schema TEXT Target DuckDB schema for seed tables. │
│ [default: reference_data] │
│ --help Show this message and exit. │
╰──────────────────────────────────────────────────────────────────────────────╯
```

21
docs/docs/cli/load.md Normal file
View File

@@ -0,0 +1,21 @@
---
title: stack load
sidebar_position: 5
---
# `stack load`
```
Usage: stack load [OPTIONS] COMMAND [ARGS]...
Ingest data (CCLF, BCDA, seeds).
╭─ Options ────────────────────────────────────────────────────────────────────╮
│ --help Show this message and exit. │
╰──────────────────────────────────────────────────────────────────────────────╯
╭─ Commands ───────────────────────────────────────────────────────────────────╮
│ cclf Ingest CCLF claim files into DuckDB. │
│ bcda Flatten BCDA FHIR exports and load into DuckDB. │
│ seed Load seed/reference data (CSV, Excel, Parquet) into DuckDB. │
╰──────────────────────────────────────────────────────────────────────────────╯
```

22
docs/docs/cli/run.md Normal file
View File

@@ -0,0 +1,22 @@
---
title: stack run
sidebar_position: 2
---
# `stack run`
```
Usage: stack run [OPTIONS] NAME
Execute a named pipeline against the chosen target context.
╭─ Arguments ──────────────────────────────────────────────────────────────────╮
│ * name TEXT Pipeline name (e.g. readmissions). [required] │
╰──────────────────────────────────────────────────────────────────────────────╯
╭─ Options ────────────────────────────────────────────────────────────────────╮
│ --target TEXT Target context: local, lake, trino, databricks. │
│ Defaults to stack.toml. │
│ --save Save pipeline outputs back to the database. │
│ --help Show this message and exit. │
╰──────────────────────────────────────────────────────────────────────────────╯
```

31
docs/docs/cli/stack.md Normal file
View File

@@ -0,0 +1,31 @@
---
title: stack
sidebar_position: 1
---
# `stack`
```
Usage: stack [OPTIONS] COMMAND [ARGS]...
Healthcare data platform CLI.
╭─ Options ────────────────────────────────────────────────────────────────────╮
│ --install-completion Install completion for the current shell. │
│ --show-completion Show completion for the current shell, to copy │
│ it or customize the installation. │
│ --help Show this message and exit. │
╰──────────────────────────────────────────────────────────────────────────────╯
╭─ Commands ───────────────────────────────────────────────────────────────────╮
│ run Execute a named pipeline against the chosen target context. │
│ validate Verify pipeline output contracts against SQLTable models. │
│ health Run health checks on all platform services. │
│ load Ingest data (CCLF, BCDA, seeds). │
│ generate Regenerate code artefacts. │
│ bib Bibliography operations. │
│ lake Lakehouse schema and data. │
│ db DuckDB utilities. │
│ docs Documentation generation. │
│ api API server. │
╰──────────────────────────────────────────────────────────────────────────────╯
```

25
docs/docs/cli/validate.md Normal file
View File

@@ -0,0 +1,25 @@
---
title: stack validate
sidebar_position: 3
---
# `stack validate`
```
Usage: stack validate [OPTIONS] [PIPELINE]
Verify pipeline output contracts against SQLTable models.
Runs each pipeline and checks that every output DataFrame matches
the expected columns from its SQLTable contract. Reports mismatches
without saving anything.
╭─ Arguments ──────────────────────────────────────────────────────────────────╮
│ pipeline [PIPELINE] Pipeline name to validate (all if omitted). │
╰──────────────────────────────────────────────────────────────────────────────╯
╭─ Options ────────────────────────────────────────────────────────────────────╮
│ --target TEXT Target context: local, lake, trino, databricks. │
│ [default: local] │
│ --help Show this message and exit. │
╰──────────────────────────────────────────────────────────────────────────────╯
```

514
docs/docs/dag.md Normal file
View File

@@ -0,0 +1,514 @@
---
title: Pipeline DAG
sidebar_position: 13
---
# Pipeline DAG
## Pipeline Dependencies
High-level view of how pipelines depend on each other.
```mermaid
graph LR
ahrq_measures[ahrq_measures]
cclf[cclf]
claims_preprocessing[claims_preprocessing]
cms_quality_measures[cms_quality_measures]
core[core]
data_quality[data_quality]
hcc_suspecting[hcc_suspecting]
input_layer[input_layer]
main[main]
pharmacy[pharmacy]
provider_attribution[provider_attribution]
quality_measures[quality_measures]
readmissions[readmissions]
core --> ahrq_measures
core --> cms_quality_measures
claims_preprocessing --> core
input_layer --> core
main --> data_quality
core --> hcc_suspecting
hcc_suspecting --> main
core --> pharmacy
core --> provider_attribution
core --> quality_measures
core --> readmissions
```
## Full Table Lineage
Detailed table-level dependency graph across all pipelines.
228 tables, 467 edges.
```mermaid
graph LR
ahrq_measures__stg_pqi_member_months[ahrq_measures._stg_pqi_member_months] --> ahrq_measures__int_pqi_01_denom[ahrq_measures._int_pqi_01_denom]
core_patient[core.patient] --> ahrq_measures__int_pqi_01_denom[ahrq_measures._int_pqi_01_denom]
ahrq_measures__int_pqi_shared_exclusion_union[ahrq_measures._int_pqi_shared_exclusion_union] --> ahrq_measures__int_pqi_01_exclusions[ahrq_measures._int_pqi_01_exclusions]
ahrq_measures__stg_pqi_inpatient_encounter[ahrq_measures._stg_pqi_inpatient_encounter] --> ahrq_measures__int_pqi_01_num[ahrq_measures._int_pqi_01_num]
ahrq_measures__value_set_pqi[ahrq_measures._value_set_pqi] --> ahrq_measures__int_pqi_01_num[ahrq_measures._int_pqi_01_num]
ahrq_measures__int_pqi_01_denom[ahrq_measures._int_pqi_01_denom] --> ahrq_measures__int_pqi_01_num[ahrq_measures._int_pqi_01_num]
ahrq_measures__int_pqi_01_exclusions[ahrq_measures._int_pqi_01_exclusions] --> ahrq_measures__int_pqi_01_num[ahrq_measures._int_pqi_01_num]
ahrq_measures__stg_pqi_member_months[ahrq_measures._stg_pqi_member_months] --> ahrq_measures__int_pqi_03_denom[ahrq_measures._int_pqi_03_denom]
core_patient[core.patient] --> ahrq_measures__int_pqi_03_denom[ahrq_measures._int_pqi_03_denom]
ahrq_measures__int_pqi_shared_exclusion_union[ahrq_measures._int_pqi_shared_exclusion_union] --> ahrq_measures__int_pqi_03_exclusions[ahrq_measures._int_pqi_03_exclusions]
ahrq_measures__stg_pqi_inpatient_encounter[ahrq_measures._stg_pqi_inpatient_encounter] --> ahrq_measures__int_pqi_03_num[ahrq_measures._int_pqi_03_num]
ahrq_measures__value_set_pqi[ahrq_measures._value_set_pqi] --> ahrq_measures__int_pqi_03_num[ahrq_measures._int_pqi_03_num]
ahrq_measures__int_pqi_03_denom[ahrq_measures._int_pqi_03_denom] --> ahrq_measures__int_pqi_03_num[ahrq_measures._int_pqi_03_num]
ahrq_measures__int_pqi_03_exclusions[ahrq_measures._int_pqi_03_exclusions] --> ahrq_measures__int_pqi_03_num[ahrq_measures._int_pqi_03_num]
ahrq_measures__stg_pqi_member_months[ahrq_measures._stg_pqi_member_months] --> ahrq_measures__int_pqi_05_denom[ahrq_measures._int_pqi_05_denom]
core_patient[core.patient] --> ahrq_measures__int_pqi_05_denom[ahrq_measures._int_pqi_05_denom]
ahrq_measures__int_pqi_shared_exclusion_union[ahrq_measures._int_pqi_shared_exclusion_union] --> ahrq_measures__int_pqi_05_exclusions[ahrq_measures._int_pqi_05_exclusions]
ahrq_measures__value_set_pqi[ahrq_measures._value_set_pqi] --> ahrq_measures__int_pqi_05_exclusions[ahrq_measures._int_pqi_05_exclusions]
core_condition[core.condition] --> ahrq_measures__int_pqi_05_exclusions[ahrq_measures._int_pqi_05_exclusions]
ahrq_measures__stg_pqi_inpatient_encounter[ahrq_measures._stg_pqi_inpatient_encounter] --> ahrq_measures__int_pqi_05_num[ahrq_measures._int_pqi_05_num]
ahrq_measures__value_set_pqi[ahrq_measures._value_set_pqi] --> ahrq_measures__int_pqi_05_num[ahrq_measures._int_pqi_05_num]
ahrq_measures__int_pqi_05_denom[ahrq_measures._int_pqi_05_denom] --> ahrq_measures__int_pqi_05_num[ahrq_measures._int_pqi_05_num]
ahrq_measures__int_pqi_05_exclusions[ahrq_measures._int_pqi_05_exclusions] --> ahrq_measures__int_pqi_05_num[ahrq_measures._int_pqi_05_num]
ahrq_measures__stg_pqi_member_months[ahrq_measures._stg_pqi_member_months] --> ahrq_measures__int_pqi_07_denom[ahrq_measures._int_pqi_07_denom]
core_patient[core.patient] --> ahrq_measures__int_pqi_07_denom[ahrq_measures._int_pqi_07_denom]
ahrq_measures__int_pqi_shared_exclusion_union[ahrq_measures._int_pqi_shared_exclusion_union] --> ahrq_measures__int_pqi_07_exclusions[ahrq_measures._int_pqi_07_exclusions]
ahrq_measures__value_set_pqi[ahrq_measures._value_set_pqi] --> ahrq_measures__int_pqi_07_exclusions[ahrq_measures._int_pqi_07_exclusions]
core_condition[core.condition] --> ahrq_measures__int_pqi_07_exclusions[ahrq_measures._int_pqi_07_exclusions]
core_procedure[core.procedure] --> ahrq_measures__int_pqi_07_exclusions[ahrq_measures._int_pqi_07_exclusions]
ahrq_measures__stg_pqi_inpatient_encounter[ahrq_measures._stg_pqi_inpatient_encounter] --> ahrq_measures__int_pqi_07_num[ahrq_measures._int_pqi_07_num]
ahrq_measures__value_set_pqi[ahrq_measures._value_set_pqi] --> ahrq_measures__int_pqi_07_num[ahrq_measures._int_pqi_07_num]
ahrq_measures__int_pqi_07_denom[ahrq_measures._int_pqi_07_denom] --> ahrq_measures__int_pqi_07_num[ahrq_measures._int_pqi_07_num]
ahrq_measures__int_pqi_07_exclusions[ahrq_measures._int_pqi_07_exclusions] --> ahrq_measures__int_pqi_07_num[ahrq_measures._int_pqi_07_num]
ahrq_measures__stg_pqi_member_months[ahrq_measures._stg_pqi_member_months] --> ahrq_measures__int_pqi_08_denom[ahrq_measures._int_pqi_08_denom]
core_patient[core.patient] --> ahrq_measures__int_pqi_08_denom[ahrq_measures._int_pqi_08_denom]
ahrq_measures__int_pqi_shared_exclusion_union[ahrq_measures._int_pqi_shared_exclusion_union] --> ahrq_measures__int_pqi_08_exclusions[ahrq_measures._int_pqi_08_exclusions]
ahrq_measures__value_set_pqi[ahrq_measures._value_set_pqi] --> ahrq_measures__int_pqi_08_exclusions[ahrq_measures._int_pqi_08_exclusions]
core_procedure[core.procedure] --> ahrq_measures__int_pqi_08_exclusions[ahrq_measures._int_pqi_08_exclusions]
ahrq_measures__stg_pqi_inpatient_encounter[ahrq_measures._stg_pqi_inpatient_encounter] --> ahrq_measures__int_pqi_08_num[ahrq_measures._int_pqi_08_num]
ahrq_measures__value_set_pqi[ahrq_measures._value_set_pqi] --> ahrq_measures__int_pqi_08_num[ahrq_measures._int_pqi_08_num]
ahrq_measures__int_pqi_08_denom[ahrq_measures._int_pqi_08_denom] --> ahrq_measures__int_pqi_08_num[ahrq_measures._int_pqi_08_num]
ahrq_measures__int_pqi_08_exclusions[ahrq_measures._int_pqi_08_exclusions] --> ahrq_measures__int_pqi_08_num[ahrq_measures._int_pqi_08_num]
ahrq_measures__stg_pqi_member_months[ahrq_measures._stg_pqi_member_months] --> ahrq_measures__int_pqi_11_denom[ahrq_measures._int_pqi_11_denom]
core_patient[core.patient] --> ahrq_measures__int_pqi_11_denom[ahrq_measures._int_pqi_11_denom]
ahrq_measures__int_pqi_shared_exclusion_union[ahrq_measures._int_pqi_shared_exclusion_union] --> ahrq_measures__int_pqi_11_exclusions[ahrq_measures._int_pqi_11_exclusions]
ahrq_measures__value_set_pqi[ahrq_measures._value_set_pqi] --> ahrq_measures__int_pqi_11_exclusions[ahrq_measures._int_pqi_11_exclusions]
core_condition[core.condition] --> ahrq_measures__int_pqi_11_exclusions[ahrq_measures._int_pqi_11_exclusions]
core_procedure[core.procedure] --> ahrq_measures__int_pqi_11_exclusions[ahrq_measures._int_pqi_11_exclusions]
ahrq_measures__stg_pqi_inpatient_encounter[ahrq_measures._stg_pqi_inpatient_encounter] --> ahrq_measures__int_pqi_11_num[ahrq_measures._int_pqi_11_num]
ahrq_measures__value_set_pqi[ahrq_measures._value_set_pqi] --> ahrq_measures__int_pqi_11_num[ahrq_measures._int_pqi_11_num]
ahrq_measures__int_pqi_11_denom[ahrq_measures._int_pqi_11_denom] --> ahrq_measures__int_pqi_11_num[ahrq_measures._int_pqi_11_num]
ahrq_measures__int_pqi_11_exclusions[ahrq_measures._int_pqi_11_exclusions] --> ahrq_measures__int_pqi_11_num[ahrq_measures._int_pqi_11_num]
ahrq_measures__stg_pqi_member_months[ahrq_measures._stg_pqi_member_months] --> ahrq_measures__int_pqi_12_denom[ahrq_measures._int_pqi_12_denom]
core_patient[core.patient] --> ahrq_measures__int_pqi_12_denom[ahrq_measures._int_pqi_12_denom]
ahrq_measures__int_pqi_shared_exclusion_union[ahrq_measures._int_pqi_shared_exclusion_union] --> ahrq_measures__int_pqi_12_exclusions[ahrq_measures._int_pqi_12_exclusions]
ahrq_measures__value_set_pqi[ahrq_measures._value_set_pqi] --> ahrq_measures__int_pqi_12_exclusions[ahrq_measures._int_pqi_12_exclusions]
core_condition[core.condition] --> ahrq_measures__int_pqi_12_exclusions[ahrq_measures._int_pqi_12_exclusions]
core_procedure[core.procedure] --> ahrq_measures__int_pqi_12_exclusions[ahrq_measures._int_pqi_12_exclusions]
ahrq_measures__stg_pqi_inpatient_encounter[ahrq_measures._stg_pqi_inpatient_encounter] --> ahrq_measures__int_pqi_12_num[ahrq_measures._int_pqi_12_num]
ahrq_measures__value_set_pqi[ahrq_measures._value_set_pqi] --> ahrq_measures__int_pqi_12_num[ahrq_measures._int_pqi_12_num]
ahrq_measures__int_pqi_12_denom[ahrq_measures._int_pqi_12_denom] --> ahrq_measures__int_pqi_12_num[ahrq_measures._int_pqi_12_num]
ahrq_measures__int_pqi_12_exclusions[ahrq_measures._int_pqi_12_exclusions] --> ahrq_measures__int_pqi_12_num[ahrq_measures._int_pqi_12_num]
ahrq_measures__stg_pqi_member_months[ahrq_measures._stg_pqi_member_months] --> ahrq_measures__int_pqi_14_denom[ahrq_measures._int_pqi_14_denom]
core_patient[core.patient] --> ahrq_measures__int_pqi_14_denom[ahrq_measures._int_pqi_14_denom]
ahrq_measures__int_pqi_shared_exclusion_union[ahrq_measures._int_pqi_shared_exclusion_union] --> ahrq_measures__int_pqi_14_exclusions[ahrq_measures._int_pqi_14_exclusions]
ahrq_measures__stg_pqi_inpatient_encounter[ahrq_measures._stg_pqi_inpatient_encounter] --> ahrq_measures__int_pqi_14_num[ahrq_measures._int_pqi_14_num]
ahrq_measures__value_set_pqi[ahrq_measures._value_set_pqi] --> ahrq_measures__int_pqi_14_num[ahrq_measures._int_pqi_14_num]
ahrq_measures__int_pqi_14_denom[ahrq_measures._int_pqi_14_denom] --> ahrq_measures__int_pqi_14_num[ahrq_measures._int_pqi_14_num]
ahrq_measures__int_pqi_14_exclusions[ahrq_measures._int_pqi_14_exclusions] --> ahrq_measures__int_pqi_14_num[ahrq_measures._int_pqi_14_num]
ahrq_measures__stg_pqi_member_months[ahrq_measures._stg_pqi_member_months] --> ahrq_measures__int_pqi_15_denom[ahrq_measures._int_pqi_15_denom]
core_patient[core.patient] --> ahrq_measures__int_pqi_15_denom[ahrq_measures._int_pqi_15_denom]
ahrq_measures__int_pqi_shared_exclusion_union[ahrq_measures._int_pqi_shared_exclusion_union] --> ahrq_measures__int_pqi_15_exclusions[ahrq_measures._int_pqi_15_exclusions]
ahrq_measures__value_set_pqi[ahrq_measures._value_set_pqi] --> ahrq_measures__int_pqi_15_exclusions[ahrq_measures._int_pqi_15_exclusions]
core_condition[core.condition] --> ahrq_measures__int_pqi_15_exclusions[ahrq_measures._int_pqi_15_exclusions]
ahrq_measures__stg_pqi_inpatient_encounter[ahrq_measures._stg_pqi_inpatient_encounter] --> ahrq_measures__int_pqi_15_num[ahrq_measures._int_pqi_15_num]
ahrq_measures__value_set_pqi[ahrq_measures._value_set_pqi] --> ahrq_measures__int_pqi_15_num[ahrq_measures._int_pqi_15_num]
ahrq_measures__int_pqi_15_denom[ahrq_measures._int_pqi_15_denom] --> ahrq_measures__int_pqi_15_num[ahrq_measures._int_pqi_15_num]
ahrq_measures__int_pqi_15_exclusions[ahrq_measures._int_pqi_15_exclusions] --> ahrq_measures__int_pqi_15_num[ahrq_measures._int_pqi_15_num]
ahrq_measures__stg_pqi_member_months[ahrq_measures._stg_pqi_member_months] --> ahrq_measures__int_pqi_16_denom[ahrq_measures._int_pqi_16_denom]
core_patient[core.patient] --> ahrq_measures__int_pqi_16_denom[ahrq_measures._int_pqi_16_denom]
ahrq_measures__int_pqi_shared_exclusion_union[ahrq_measures._int_pqi_shared_exclusion_union] --> ahrq_measures__int_pqi_16_exclusions[ahrq_measures._int_pqi_16_exclusions]
ahrq_measures__value_set_pqi[ahrq_measures._value_set_pqi] --> ahrq_measures__int_pqi_16_exclusions[ahrq_measures._int_pqi_16_exclusions]
core_condition[core.condition] --> ahrq_measures__int_pqi_16_exclusions[ahrq_measures._int_pqi_16_exclusions]
ahrq_measures__stg_pqi_inpatient_encounter[ahrq_measures._stg_pqi_inpatient_encounter] --> ahrq_measures__int_pqi_16_num[ahrq_measures._int_pqi_16_num]
ahrq_measures__value_set_pqi[ahrq_measures._value_set_pqi] --> ahrq_measures__int_pqi_16_num[ahrq_measures._int_pqi_16_num]
ahrq_measures__int_pqi_16_denom[ahrq_measures._int_pqi_16_denom] --> ahrq_measures__int_pqi_16_num[ahrq_measures._int_pqi_16_num]
ahrq_measures__int_pqi_16_exclusions[ahrq_measures._int_pqi_16_exclusions] --> ahrq_measures__int_pqi_16_num[ahrq_measures._int_pqi_16_num]
core_condition[core.condition] --> ahrq_measures__int_pqi_16_num[ahrq_measures._int_pqi_16_num]
core_procedure[core.procedure] --> ahrq_measures__int_pqi_16_num[ahrq_measures._int_pqi_16_num]
ahrq_measures__stg_pqi_inpatient_encounter[ahrq_measures._stg_pqi_inpatient_encounter] --> ahrq_measures__int_pqi_shared_exclusion_missing_dates[ahrq_measures._int_pqi_shared_exclusion_missing_dates]
core_patient[core.patient] --> ahrq_measures__int_pqi_shared_exclusion_missing_gender[ahrq_measures._int_pqi_shared_exclusion_missing_gender]
ahrq_measures__stg_pqi_inpatient_encounter[ahrq_measures._stg_pqi_inpatient_encounter] --> ahrq_measures__int_pqi_shared_exclusion_missing_primary_dx[ahrq_measures._int_pqi_shared_exclusion_missing_primary_dx]
ahrq_measures__stg_pqi_inpatient_encounter[ahrq_measures._stg_pqi_inpatient_encounter] --> ahrq_measures__int_pqi_shared_exclusion_transfer[ahrq_measures._int_pqi_shared_exclusion_transfer]
ahrq_measures__stg_pqi_inpatient_encounter[ahrq_measures._stg_pqi_inpatient_encounter] --> ahrq_measures__int_pqi_shared_exclusion_ungroupable_drg[ahrq_measures._int_pqi_shared_exclusion_ungroupable_drg]
ahrq_measures__stg_pqi_inpatient_encounter[ahrq_measures._stg_pqi_inpatient_encounter] --> ahrq_measures__int_pqi_shared_exclusion_union[ahrq_measures._int_pqi_shared_exclusion_union]
ahrq_measures__int_pqi_shared_exclusions_missing_age[ahrq_measures._int_pqi_shared_exclusions_missing_age] --> ahrq_measures__int_pqi_shared_exclusion_union[ahrq_measures._int_pqi_shared_exclusion_union]
ahrq_measures__int_pqi_shared_exclusion_missing_gender[ahrq_measures._int_pqi_shared_exclusion_missing_gender] --> ahrq_measures__int_pqi_shared_exclusion_union[ahrq_measures._int_pqi_shared_exclusion_union]
ahrq_measures__int_pqi_shared_exclusion_missing_dates[ahrq_measures._int_pqi_shared_exclusion_missing_dates] --> ahrq_measures__int_pqi_shared_exclusion_union[ahrq_measures._int_pqi_shared_exclusion_union]
ahrq_measures__int_pqi_shared_exclusion_missing_primary_dx[ahrq_measures._int_pqi_shared_exclusion_missing_primary_dx] --> ahrq_measures__int_pqi_shared_exclusion_union[ahrq_measures._int_pqi_shared_exclusion_union]
ahrq_measures__int_pqi_shared_exclusion_transfer[ahrq_measures._int_pqi_shared_exclusion_transfer] --> ahrq_measures__int_pqi_shared_exclusion_union[ahrq_measures._int_pqi_shared_exclusion_union]
ahrq_measures__int_pqi_shared_exclusion_ungroupable_drg[ahrq_measures._int_pqi_shared_exclusion_ungroupable_drg] --> ahrq_measures__int_pqi_shared_exclusion_union[ahrq_measures._int_pqi_shared_exclusion_union]
core_patient[core.patient] --> ahrq_measures__int_pqi_shared_exclusions_missing_age[ahrq_measures._int_pqi_shared_exclusions_missing_age]
core_encounter[core.encounter] --> ahrq_measures__stg_pqi_inpatient_encounter[ahrq_measures._stg_pqi_inpatient_encounter]
core_member_months[core.member_months] --> ahrq_measures__stg_pqi_member_months[ahrq_measures._stg_pqi_member_months]
reference_data_calendar[reference_data.calendar] --> ahrq_measures__stg_pqi_member_months[ahrq_measures._stg_pqi_member_months]
cclf_cclf4[cclf.cclf4] --> cclf__int_diagnosis_pivot[cclf._int_diagnosis_pivot]
cclf__stg_dme_claim[cclf._stg_dme_claim] --> cclf__int_dme_claim_adr[cclf._int_dme_claim_adr]
cclf__int_dme_claim_adr[cclf._int_dme_claim_adr] --> cclf__int_dme_medical_claim[cclf._int_dme_medical_claim]
cclf__stg_institutional_header[cclf._stg_institutional_header] --> cclf__int_institutional_header_adr[cclf._int_institutional_header_adr]
cclf__int_institutional_header_adr[cclf._int_institutional_header_adr] --> cclf__int_institutional_medical_claim[cclf._int_institutional_medical_claim]
cclf__stg_revenue_center[cclf._stg_revenue_center] --> cclf__int_institutional_medical_claim[cclf._int_institutional_medical_claim]
cclf__int_diagnosis_pivot[cclf._int_diagnosis_pivot] --> cclf__int_institutional_medical_claim[cclf._int_institutional_medical_claim]
cclf__int_procedure_pivot[cclf._int_procedure_pivot] --> cclf__int_institutional_medical_claim[cclf._int_institutional_medical_claim]
cclf__stg_pharmacy_claim[cclf._stg_pharmacy_claim] --> cclf__int_pharmacy_claim_adr[cclf._int_pharmacy_claim_adr]
cclf__stg_physician_claim[cclf._stg_physician_claim] --> cclf__int_physician_claim_adr[cclf._int_physician_claim_adr]
cclf__int_physician_claim_adr[cclf._int_physician_claim_adr] --> cclf__int_physician_medical_claim[cclf._int_physician_medical_claim]
cclf_cclf3[cclf.cclf3] --> cclf__int_procedure_pivot[cclf._int_procedure_pivot]
cclf_cclf8[cclf.cclf8] --> cclf__stg_beneficiary_demographics[cclf._stg_beneficiary_demographics]
cclf__stg_beneficiary_xref[cclf._stg_beneficiary_xref] --> cclf__stg_beneficiary_demographics[cclf._stg_beneficiary_demographics]
cclf_cclf9[cclf.cclf9] --> cclf__stg_beneficiary_xref[cclf._stg_beneficiary_xref]
cclf_cclf6[cclf.cclf6] --> cclf__stg_dme_claim[cclf._stg_dme_claim]
cclf__stg_beneficiary_xref[cclf._stg_beneficiary_xref] --> cclf__stg_dme_claim[cclf._stg_dme_claim]
cclf_cclf1[cclf.cclf1] --> cclf__stg_institutional_header[cclf._stg_institutional_header]
cclf__stg_beneficiary_xref[cclf._stg_beneficiary_xref] --> cclf__stg_institutional_header[cclf._stg_institutional_header]
cclf_cclf7[cclf.cclf7] --> cclf__stg_pharmacy_claim[cclf._stg_pharmacy_claim]
cclf__stg_beneficiary_xref[cclf._stg_beneficiary_xref] --> cclf__stg_pharmacy_claim[cclf._stg_pharmacy_claim]
cclf_cclf5[cclf.cclf5] --> cclf__stg_physician_claim[cclf._stg_physician_claim]
cclf__stg_beneficiary_xref[cclf._stg_beneficiary_xref] --> cclf__stg_physician_claim[cclf._stg_physician_claim]
cclf_cclf2[cclf.cclf2] --> cclf__stg_revenue_center[cclf._stg_revenue_center]
cclf__stg_beneficiary_xref[cclf._stg_beneficiary_xref] --> cclf__stg_revenue_center[cclf._stg_revenue_center]
cclf__stg_beneficiary_demographics[cclf._stg_beneficiary_demographics] --> cclf_eligibility[cclf.eligibility]
cclf__int_institutional_medical_claim[cclf._int_institutional_medical_claim] --> cclf_medical_claim[cclf.medical_claim]
cclf__int_physician_medical_claim[cclf._int_physician_medical_claim] --> cclf_medical_claim[cclf.medical_claim]
cclf__int_dme_medical_claim[cclf._int_dme_medical_claim] --> cclf_medical_claim[cclf.medical_claim]
cclf__int_pharmacy_claim_adr[cclf._int_pharmacy_claim_adr] --> cclf_pharmacy_claim[cclf.pharmacy_claim]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_ambulance__anchor_events[claims_preprocessing.ambulance__anchor_events]
claims_preprocessing_ambulance__anchor_events[claims_preprocessing.ambulance__anchor_events] --> claims_preprocessing_ambulance__generate_encounter_id[claims_preprocessing.ambulance__generate_encounter_id]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_ambulance__generate_encounter_id[claims_preprocessing.ambulance__generate_encounter_id]
claims_preprocessing_ambulance__generate_encounter_id[claims_preprocessing.ambulance__generate_encounter_id] --> claims_preprocessing_ambulance__match_claims_to_anchor[claims_preprocessing.ambulance__match_claims_to_anchor]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_ambulance__match_claims_to_anchor[claims_preprocessing.ambulance__match_claims_to_anchor]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_asc__anchor_events[claims_preprocessing.asc__anchor_events]
claims_preprocessing_asc__anchor_events[claims_preprocessing.asc__anchor_events] --> claims_preprocessing_asc__generate_encounter_id[claims_preprocessing.asc__generate_encounter_id]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_asc__generate_encounter_id[claims_preprocessing.asc__generate_encounter_id]
claims_preprocessing_asc__start_end_dates[claims_preprocessing.asc__start_end_dates] --> claims_preprocessing_asc__match_claims_to_anchor[claims_preprocessing.asc__match_claims_to_anchor]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_asc__match_claims_to_anchor[claims_preprocessing.asc__match_claims_to_anchor]
claims_preprocessing_asc__generate_encounter_id[claims_preprocessing.asc__generate_encounter_id] --> claims_preprocessing_asc__start_end_dates[claims_preprocessing.asc__start_end_dates]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_dialysis__anchor_events[claims_preprocessing.dialysis__anchor_events]
claims_preprocessing_dialysis__anchor_events[claims_preprocessing.dialysis__anchor_events] --> claims_preprocessing_dialysis__generate_encounter_id[claims_preprocessing.dialysis__generate_encounter_id]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_dialysis__generate_encounter_id[claims_preprocessing.dialysis__generate_encounter_id]
claims_preprocessing_dialysis__generate_encounter_id[claims_preprocessing.dialysis__generate_encounter_id] --> claims_preprocessing_dialysis__match_claims_to_anchor[claims_preprocessing.dialysis__match_claims_to_anchor]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_dialysis__match_claims_to_anchor[claims_preprocessing.dialysis__match_claims_to_anchor]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_dme__anchor_events[claims_preprocessing.dme__anchor_events]
claims_preprocessing_dme__anchor_events[claims_preprocessing.dme__anchor_events] --> claims_preprocessing_dme__generate_encounter_id[claims_preprocessing.dme__generate_encounter_id]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_dme__generate_encounter_id[claims_preprocessing.dme__generate_encounter_id]
claims_preprocessing_dme__generate_encounter_id[claims_preprocessing.dme__generate_encounter_id] --> claims_preprocessing_dme__match_claims_to_anchor[claims_preprocessing.dme__match_claims_to_anchor]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_dme__match_claims_to_anchor[claims_preprocessing.dme__match_claims_to_anchor]
claims_preprocessing_encounters__combined_claim_line_crosswalk[claims_preprocessing.encounters__combined_claim_line_crosswalk] --> claims_preprocessing_encounters__orphaned_claims[claims_preprocessing.encounters__orphaned_claims]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_encounters__orphaned_claims[claims_preprocessing.encounters__orphaned_claims]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_home_health__anchor_events[claims_preprocessing.home_health__anchor_events]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_home_health__generate_encounter_id[claims_preprocessing.home_health__generate_encounter_id]
claims_preprocessing_home_health__anchor_events[claims_preprocessing.home_health__anchor_events] --> claims_preprocessing_home_health__generate_encounter_id[claims_preprocessing.home_health__generate_encounter_id]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_home_health__match_claims_to_anchor[claims_preprocessing.home_health__match_claims_to_anchor]
claims_preprocessing_home_health__generate_encounter_id[claims_preprocessing.home_health__generate_encounter_id] --> claims_preprocessing_home_health__match_claims_to_anchor[claims_preprocessing.home_health__match_claims_to_anchor]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_lab__anchor_events[claims_preprocessing.lab__anchor_events]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_lab__generate_encounter_id[claims_preprocessing.lab__generate_encounter_id]
claims_preprocessing_lab__anchor_events[claims_preprocessing.lab__anchor_events] --> claims_preprocessing_lab__generate_encounter_id[claims_preprocessing.lab__generate_encounter_id]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_lab__match_claims_to_anchor[claims_preprocessing.lab__match_claims_to_anchor]
claims_preprocessing_lab__generate_encounter_id[claims_preprocessing.lab__generate_encounter_id] --> claims_preprocessing_lab__match_claims_to_anchor[claims_preprocessing.lab__match_claims_to_anchor]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_office_visits__int_office_visits_injections[claims_preprocessing.office_visits__int_office_visits_injections]
claims_preprocessing_office_visits__int_office_visits[claims_preprocessing.office_visits__int_office_visits] --> claims_preprocessing_office_visits__int_office_visits_injections[claims_preprocessing.office_visits__int_office_visits_injections]
claims_preprocessing_office_visits__int_office_visits[claims_preprocessing.office_visits__int_office_visits] --> claims_preprocessing_office_visits__int_office_visits_ptotst[claims_preprocessing.office_visits__int_office_visits_ptotst]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_office_visits__int_office_visits_radiology[claims_preprocessing.office_visits__int_office_visits_radiology]
claims_preprocessing_office_visits__int_office_visits[claims_preprocessing.office_visits__int_office_visits] --> claims_preprocessing_office_visits__int_office_visits_radiology[claims_preprocessing.office_visits__int_office_visits_radiology]
claims_preprocessing_service_category__office_based_radiology[claims_preprocessing.service_category__office_based_radiology] --> claims_preprocessing_office_visits__int_office_visits_radiology[claims_preprocessing.office_visits__int_office_visits_radiology]
claims_preprocessing_office_visits__int_office_visits[claims_preprocessing.office_visits__int_office_visits] --> claims_preprocessing_office_visits__int_office_visits_surgery[claims_preprocessing.office_visits__int_office_visits_surgery]
claims_preprocessing_office_visits__int_office_visits[claims_preprocessing.office_visits__int_office_visits] --> claims_preprocessing_office_visits__int_office_visits_telehealth[claims_preprocessing.office_visits__int_office_visits_telehealth]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_outpatient_hospice__anchor_events[claims_preprocessing.outpatient_hospice__anchor_events]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_outpatient_hospice__generate_encounter_id[claims_preprocessing.outpatient_hospice__generate_encounter_id]
claims_preprocessing_outpatient_hospice__anchor_events[claims_preprocessing.outpatient_hospice__anchor_events] --> claims_preprocessing_outpatient_hospice__generate_encounter_id[claims_preprocessing.outpatient_hospice__generate_encounter_id]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_outpatient_hospice__match_claims_to_anchor[claims_preprocessing.outpatient_hospice__match_claims_to_anchor]
claims_preprocessing_outpatient_hospice__generate_encounter_id[claims_preprocessing.outpatient_hospice__generate_encounter_id] --> claims_preprocessing_outpatient_hospice__match_claims_to_anchor[claims_preprocessing.outpatient_hospice__match_claims_to_anchor]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_outpatient_hospital_or_clinic__anchor_events[claims_preprocessing.outpatient_hospital_or_clinic__anchor_events]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_outpatient_hospital_or_clinic__generate_encounter_id[claims_preprocessing.outpatient_hospital_or_clinic__generate_encounter_id]
claims_preprocessing_outpatient_hospital_or_clinic__anchor_events[claims_preprocessing.outpatient_hospital_or_clinic__anchor_events] --> claims_preprocessing_outpatient_hospital_or_clinic__generate_encounter_id[claims_preprocessing.outpatient_hospital_or_clinic__generate_encounter_id]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_outpatient_hospital_or_clinic__match_claims_to_anchor[claims_preprocessing.outpatient_hospital_or_clinic__match_claims_to_anchor]
claims_preprocessing_outpatient_hospital_or_clinic__generate_encounter_id[claims_preprocessing.outpatient_hospital_or_clinic__generate_encounter_id] --> claims_preprocessing_outpatient_hospital_or_clinic__match_claims_to_anchor[claims_preprocessing.outpatient_hospital_or_clinic__match_claims_to_anchor]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_outpatient_injections__anchor_events[claims_preprocessing.outpatient_injections__anchor_events]
claims_preprocessing_encounters__stg_outpatient_institutional[claims_preprocessing.encounters__stg_outpatient_institutional] --> claims_preprocessing_outpatient_injections__anchor_events[claims_preprocessing.outpatient_injections__anchor_events]
claims_preprocessing_outpatient_injections__anchor_events[claims_preprocessing.outpatient_injections__anchor_events] --> claims_preprocessing_outpatient_injections__generate_encounter_id[claims_preprocessing.outpatient_injections__generate_encounter_id]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_outpatient_injections__match_claims_to_anchor[claims_preprocessing.outpatient_injections__match_claims_to_anchor]
claims_preprocessing_outpatient_injections__generate_encounter_id[claims_preprocessing.outpatient_injections__generate_encounter_id] --> claims_preprocessing_outpatient_injections__match_claims_to_anchor[claims_preprocessing.outpatient_injections__match_claims_to_anchor]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_outpatient_psych__anchor_events[claims_preprocessing.outpatient_psych__anchor_events]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_outpatient_psych__generate_encounter_id[claims_preprocessing.outpatient_psych__generate_encounter_id]
claims_preprocessing_outpatient_psych__anchor_events[claims_preprocessing.outpatient_psych__anchor_events] --> claims_preprocessing_outpatient_psych__generate_encounter_id[claims_preprocessing.outpatient_psych__generate_encounter_id]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_outpatient_psych__match_claims_to_anchor[claims_preprocessing.outpatient_psych__match_claims_to_anchor]
claims_preprocessing_outpatient_psych__generate_encounter_id[claims_preprocessing.outpatient_psych__generate_encounter_id] --> claims_preprocessing_outpatient_psych__match_claims_to_anchor[claims_preprocessing.outpatient_psych__match_claims_to_anchor]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_outpatient_ptotst__anchor_events[claims_preprocessing.outpatient_ptotst__anchor_events]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_outpatient_ptotst__generate_encounter_id[claims_preprocessing.outpatient_ptotst__generate_encounter_id]
claims_preprocessing_outpatient_ptotst__anchor_events[claims_preprocessing.outpatient_ptotst__anchor_events] --> claims_preprocessing_outpatient_ptotst__generate_encounter_id[claims_preprocessing.outpatient_ptotst__generate_encounter_id]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_outpatient_ptotst__match_claims_to_anchor[claims_preprocessing.outpatient_ptotst__match_claims_to_anchor]
claims_preprocessing_outpatient_ptotst__generate_encounter_id[claims_preprocessing.outpatient_ptotst__generate_encounter_id] --> claims_preprocessing_outpatient_ptotst__match_claims_to_anchor[claims_preprocessing.outpatient_ptotst__match_claims_to_anchor]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_outpatient_radiology__anchor_events[claims_preprocessing.outpatient_radiology__anchor_events]
claims_preprocessing_outpatient_radiology__anchor_events[claims_preprocessing.outpatient_radiology__anchor_events] --> claims_preprocessing_outpatient_radiology__generate_encounter_id[claims_preprocessing.outpatient_radiology__generate_encounter_id]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_outpatient_radiology__match_claims_to_anchor[claims_preprocessing.outpatient_radiology__match_claims_to_anchor]
claims_preprocessing_outpatient_radiology__generate_encounter_id[claims_preprocessing.outpatient_radiology__generate_encounter_id] --> claims_preprocessing_outpatient_radiology__match_claims_to_anchor[claims_preprocessing.outpatient_radiology__match_claims_to_anchor]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_outpatient_rehab__anchor_events[claims_preprocessing.outpatient_rehab__anchor_events]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_outpatient_rehab__generate_encounter_id[claims_preprocessing.outpatient_rehab__generate_encounter_id]
claims_preprocessing_outpatient_rehab__anchor_events[claims_preprocessing.outpatient_rehab__anchor_events] --> claims_preprocessing_outpatient_rehab__generate_encounter_id[claims_preprocessing.outpatient_rehab__generate_encounter_id]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_outpatient_rehab__match_claims_to_anchor[claims_preprocessing.outpatient_rehab__match_claims_to_anchor]
claims_preprocessing_outpatient_rehab__generate_encounter_id[claims_preprocessing.outpatient_rehab__generate_encounter_id] --> claims_preprocessing_outpatient_rehab__match_claims_to_anchor[claims_preprocessing.outpatient_rehab__match_claims_to_anchor]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_outpatient_substance_use__anchor_events[claims_preprocessing.outpatient_substance_use__anchor_events]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_outpatient_substance_use__generate_encounter_id[claims_preprocessing.outpatient_substance_use__generate_encounter_id]
claims_preprocessing_outpatient_substance_use__anchor_events[claims_preprocessing.outpatient_substance_use__anchor_events] --> claims_preprocessing_outpatient_substance_use__generate_encounter_id[claims_preprocessing.outpatient_substance_use__generate_encounter_id]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_outpatient_substance_use__match_claims_to_anchor[claims_preprocessing.outpatient_substance_use__match_claims_to_anchor]
claims_preprocessing_outpatient_substance_use__generate_encounter_id[claims_preprocessing.outpatient_substance_use__generate_encounter_id] --> claims_preprocessing_outpatient_substance_use__match_claims_to_anchor[claims_preprocessing.outpatient_substance_use__match_claims_to_anchor]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_outpatient_surgery__anchor_events[claims_preprocessing.outpatient_surgery__anchor_events]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_outpatient_surgery__generate_encounter_id[claims_preprocessing.outpatient_surgery__generate_encounter_id]
claims_preprocessing_outpatient_surgery__anchor_events[claims_preprocessing.outpatient_surgery__anchor_events] --> claims_preprocessing_outpatient_surgery__generate_encounter_id[claims_preprocessing.outpatient_surgery__generate_encounter_id]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_outpatient_surgery__match_claims_to_anchor[claims_preprocessing.outpatient_surgery__match_claims_to_anchor]
claims_preprocessing_outpatient_surgery__generate_encounter_id[claims_preprocessing.outpatient_surgery__generate_encounter_id] --> claims_preprocessing_outpatient_surgery__match_claims_to_anchor[claims_preprocessing.outpatient_surgery__match_claims_to_anchor]
claims_preprocessing_service_category__stg_medical_claim[claims_preprocessing.service_category__stg_medical_claim] --> claims_preprocessing_service_category__dme_institutional[claims_preprocessing.service_category__dme_institutional]
claims_preprocessing_service_category__stg_outpatient_institutional[claims_preprocessing.service_category__stg_outpatient_institutional] --> claims_preprocessing_service_category__dme_institutional[claims_preprocessing.service_category__dme_institutional]
claims_preprocessing_service_category__stg_medical_claim[claims_preprocessing.service_category__stg_medical_claim] --> claims_preprocessing_service_category__inpatient_substance_use_professional[claims_preprocessing.service_category__inpatient_substance_use_professional]
claims_preprocessing_service_category__stg_medical_claim[claims_preprocessing.service_category__stg_medical_claim] --> claims_preprocessing_service_category__outpatient_skilled_nursing_institutional[claims_preprocessing.service_category__outpatient_skilled_nursing_institutional]
claims_preprocessing_service_category__stg_medical_claim[claims_preprocessing.service_category__stg_medical_claim] --> claims_preprocessing_service_category__stg_inpatient_institutional[claims_preprocessing.service_category__stg_inpatient_institutional]
terminology_apr_drg[terminology.apr_drg] --> claims_preprocessing_service_category__stg_inpatient_institutional[claims_preprocessing.service_category__stg_inpatient_institutional]
terminology_ms_drg[terminology.ms_drg] --> claims_preprocessing_service_category__stg_inpatient_institutional[claims_preprocessing.service_category__stg_inpatient_institutional]
ccsr__value_set_dxccsr_v2023_1_cleaned_map[ccsr._value_set_dxccsr_v2023_1_cleaned_map] --> claims_preprocessing_service_category__stg_medical_claim[claims_preprocessing.service_category__stg_medical_claim]
claims_preprocessing_normalized_input_medical_claim[claims_preprocessing.normalized_input_medical_claim] --> claims_preprocessing_service_category__stg_medical_claim[claims_preprocessing.service_category__stg_medical_claim]
terminology_bill_type[terminology.bill_type] --> claims_preprocessing_service_category__stg_medical_claim[claims_preprocessing.service_category__stg_medical_claim]
terminology_ccs_services_procedures[terminology.ccs_services_procedures] --> claims_preprocessing_service_category__stg_medical_claim[claims_preprocessing.service_category__stg_medical_claim]
terminology_nitos[terminology.nitos] --> claims_preprocessing_service_category__stg_medical_claim[claims_preprocessing.service_category__stg_medical_claim]
terminology_place_of_service[terminology.place_of_service] --> claims_preprocessing_service_category__stg_medical_claim[claims_preprocessing.service_category__stg_medical_claim]
terminology_provider[terminology.provider] --> claims_preprocessing_service_category__stg_medical_claim[claims_preprocessing.service_category__stg_medical_claim]
terminology_revenue_center[terminology.revenue_center] --> claims_preprocessing_service_category__stg_medical_claim[claims_preprocessing.service_category__stg_medical_claim]
claims_preprocessing_service_category__stg_medical_claim[claims_preprocessing.service_category__stg_medical_claim] --> claims_preprocessing_service_category__stg_office_based[claims_preprocessing.service_category__stg_office_based]
claims_preprocessing_service_category__stg_professional[claims_preprocessing.service_category__stg_professional] --> claims_preprocessing_service_category__stg_office_based[claims_preprocessing.service_category__stg_office_based]
claims_preprocessing_service_category__stg_inpatient_institutional[claims_preprocessing.service_category__stg_inpatient_institutional] --> claims_preprocessing_service_category__stg_outpatient_institutional[claims_preprocessing.service_category__stg_outpatient_institutional]
claims_preprocessing_service_category__stg_medical_claim[claims_preprocessing.service_category__stg_medical_claim] --> claims_preprocessing_service_category__stg_outpatient_institutional[claims_preprocessing.service_category__stg_outpatient_institutional]
claims_preprocessing_service_category__stg_medical_claim[claims_preprocessing.service_category__stg_medical_claim] --> claims_preprocessing_service_category__stg_professional[claims_preprocessing.service_category__stg_professional]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_urgent_care__anchor_events[claims_preprocessing.urgent_care__anchor_events]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_urgent_care__generate_encounter_id[claims_preprocessing.urgent_care__generate_encounter_id]
claims_preprocessing_urgent_care__anchor_events[claims_preprocessing.urgent_care__anchor_events] --> claims_preprocessing_urgent_care__generate_encounter_id[claims_preprocessing.urgent_care__generate_encounter_id]
claims_preprocessing_encounters__stg_medical_claim[claims_preprocessing.encounters__stg_medical_claim] --> claims_preprocessing_urgent_care__match_claims_to_anchor[claims_preprocessing.urgent_care__match_claims_to_anchor]
claims_preprocessing_urgent_care__generate_encounter_id[claims_preprocessing.urgent_care__generate_encounter_id] --> claims_preprocessing_urgent_care__match_claims_to_anchor[claims_preprocessing.urgent_care__match_claims_to_anchor]
core_encounter[core.encounter] --> cms_quality_measures__acr_int_index_admission[cms_quality_measures._acr_int_index_admission]
cms_quality_measures__acr_value_set_exclusions[cms_quality_measures._acr_value_set_exclusions] --> cms_quality_measures__acr_int_index_admission[cms_quality_measures._acr_int_index_admission]
cms_quality_measures__acr_value_set_ccs_icd10_cm[cms_quality_measures._acr_value_set_ccs_icd10_cm] --> cms_quality_measures__acr_int_index_admission[cms_quality_measures._acr_int_index_admission]
core_encounter[core.encounter] --> cms_quality_measures__acr_int_planned_readmission[cms_quality_measures._acr_int_planned_readmission]
cms_quality_measures__acr_int_index_admission[cms_quality_measures._acr_int_index_admission] --> cms_quality_measures__acr_int_planned_readmission[cms_quality_measures._acr_int_planned_readmission]
cms_quality_measures__acr_value_set_paa1[cms_quality_measures._acr_value_set_paa1] --> cms_quality_measures__acr_int_planned_readmission[cms_quality_measures._acr_int_planned_readmission]
cms_quality_measures__acr_value_set_paa2[cms_quality_measures._acr_value_set_paa2] --> cms_quality_measures__acr_int_planned_readmission[cms_quality_measures._acr_int_planned_readmission]
cms_quality_measures__acr_value_set_paa3[cms_quality_measures._acr_value_set_paa3] --> cms_quality_measures__acr_int_planned_readmission[cms_quality_measures._acr_int_planned_readmission]
cms_quality_measures__acr_value_set_paa4[cms_quality_measures._acr_value_set_paa4] --> cms_quality_measures__acr_int_planned_readmission[cms_quality_measures._acr_int_planned_readmission]
cms_quality_measures__acr_value_set_ccs_icd10_cm[cms_quality_measures._acr_value_set_ccs_icd10_cm] --> cms_quality_measures__acr_int_planned_readmission[cms_quality_measures._acr_int_planned_readmission]
cms_quality_measures__acr_value_set_ccs_icd10_pcs[cms_quality_measures._acr_value_set_ccs_icd10_pcs] --> cms_quality_measures__acr_int_planned_readmission[cms_quality_measures._acr_int_planned_readmission]
cms_quality_measures__acr_int_index_admission[cms_quality_measures._acr_int_index_admission] --> cms_quality_measures__acr_int_specialty_cohort[cms_quality_measures._acr_int_specialty_cohort]
cms_quality_measures__acr_value_set_cohort_ccs[cms_quality_measures._acr_value_set_cohort_ccs] --> cms_quality_measures__acr_int_specialty_cohort[cms_quality_measures._acr_int_specialty_cohort]
cms_quality_measures__acr_value_set_cohort_icd10[cms_quality_measures._acr_value_set_cohort_icd10] --> cms_quality_measures__acr_int_specialty_cohort[cms_quality_measures._acr_int_specialty_cohort]
core_procedure[core.procedure] --> cms_quality_measures__acr_int_specialty_cohort[cms_quality_measures._acr_int_specialty_cohort]
cms_quality_measures__acr_performance_period[cms_quality_measures._acr_performance_period] --> cms_quality_measures__acr_performance_period[cms_quality_measures._acr_performance_period]
core_encounter[core.encounter] --> cms_quality_measures__hwr_int_denominator[cms_quality_measures._hwr_int_denominator]
cms_quality_measures__hwr_value_set_cohort_exclusions[cms_quality_measures._hwr_value_set_cohort_exclusions] --> cms_quality_measures__hwr_int_denominator[cms_quality_measures._hwr_int_denominator]
cms_quality_measures__hwr_value_set_specialty_cohort[cms_quality_measures._hwr_value_set_specialty_cohort] --> cms_quality_measures__hwr_int_denominator[cms_quality_measures._hwr_int_denominator]
cms_quality_measures__hwr_value_set_surg_gyn_cohort[cms_quality_measures._hwr_value_set_surg_gyn_cohort] --> cms_quality_measures__hwr_int_denominator[cms_quality_measures._hwr_int_denominator]
core_procedure[core.procedure] --> cms_quality_measures__hwr_int_denominator[cms_quality_measures._hwr_int_denominator]
core_encounter[core.encounter] --> cms_quality_measures__hwr_int_planned_readmission[cms_quality_measures._hwr_int_planned_readmission]
cms_quality_measures__hwr_int_denominator[cms_quality_measures._hwr_int_denominator] --> cms_quality_measures__hwr_int_planned_readmission[cms_quality_measures._hwr_int_planned_readmission]
cms_quality_measures__hwr_value_set_paa1[cms_quality_measures._hwr_value_set_paa1] --> cms_quality_measures__hwr_int_planned_readmission[cms_quality_measures._hwr_int_planned_readmission]
cms_quality_measures__hwr_value_set_paa2[cms_quality_measures._hwr_value_set_paa2] --> cms_quality_measures__hwr_int_planned_readmission[cms_quality_measures._hwr_int_planned_readmission]
cms_quality_measures__hwr_value_set_paa3[cms_quality_measures._hwr_value_set_paa3] --> cms_quality_measures__hwr_int_planned_readmission[cms_quality_measures._hwr_int_planned_readmission]
cms_quality_measures__hwr_value_set_paa4[cms_quality_measures._hwr_value_set_paa4] --> cms_quality_measures__hwr_int_planned_readmission[cms_quality_measures._hwr_int_planned_readmission]
cms_quality_measures__acr_value_set_ccs_icd10_cm[cms_quality_measures._acr_value_set_ccs_icd10_cm] --> cms_quality_measures__hwr_int_planned_readmission[cms_quality_measures._hwr_int_planned_readmission]
cms_quality_measures__hwr_performance_period[cms_quality_measures._hwr_performance_period] --> cms_quality_measures__hwr_performance_period[cms_quality_measures._hwr_performance_period]
core_medical_claim[core.medical_claim] --> cms_quality_measures__stg_medical_claim[cms_quality_measures._stg_medical_claim]
core_condition[core.condition] --> cms_quality_measures__stg_medical_claim[cms_quality_measures._stg_medical_claim]
core_medical_claim[core.medical_claim] --> cms_quality_measures__stg_medical_claim_condition[cms_quality_measures._stg_medical_claim_condition]
core_condition[core.condition] --> cms_quality_measures__stg_medical_claim_condition[cms_quality_measures._stg_medical_claim_condition]
cms_quality_measures__uamcc_int_mcc_cohort[cms_quality_measures._uamcc_int_mcc_cohort] --> cms_quality_measures__uamcc_int_denominator[cms_quality_measures._uamcc_int_denominator]
core_patient[core.patient] --> cms_quality_measures__uamcc_int_denominator[cms_quality_measures._uamcc_int_denominator]
cms_quality_measures__uamcc_performance_period[cms_quality_measures._uamcc_performance_period] --> cms_quality_measures__uamcc_int_denominator[cms_quality_measures._uamcc_int_denominator]
cms_quality_measures__uamcc_int_denominator[cms_quality_measures._uamcc_int_denominator] --> cms_quality_measures__uamcc_int_denominator_exclusion[cms_quality_measures._uamcc_int_denominator_exclusion]
core_patient[core.patient] --> cms_quality_measures__uamcc_int_denominator_exclusion[cms_quality_measures._uamcc_int_denominator_exclusion]
cms_quality_measures__stg_medical_claim_condition[cms_quality_measures._stg_medical_claim_condition] --> cms_quality_measures__uamcc_int_mcc_cohort[cms_quality_measures._uamcc_int_mcc_cohort]
cms_quality_measures__uamcc_value_set_cohort[cms_quality_measures._uamcc_value_set_cohort] --> cms_quality_measures__uamcc_int_mcc_cohort[cms_quality_measures._uamcc_int_mcc_cohort]
cms_quality_measures__stg_medical_claim[cms_quality_measures._stg_medical_claim] --> cms_quality_measures__uamcc_int_numerator[cms_quality_measures._uamcc_int_numerator]
cms_quality_measures__uamcc_int_denominator[cms_quality_measures._uamcc_int_denominator] --> cms_quality_measures__uamcc_int_numerator[cms_quality_measures._uamcc_int_numerator]
cms_quality_measures__uamcc_int_outcome_exclusion[cms_quality_measures._uamcc_int_outcome_exclusion] --> cms_quality_measures__uamcc_int_numerator[cms_quality_measures._uamcc_int_numerator]
cms_quality_measures__uamcc_value_set_ccs_icd10_cm[cms_quality_measures._uamcc_value_set_ccs_icd10_cm] --> cms_quality_measures__uamcc_int_numerator[cms_quality_measures._uamcc_int_numerator]
cms_quality_measures__stg_medical_claim[cms_quality_measures._stg_medical_claim] --> cms_quality_measures__uamcc_int_outcome_exclusion[cms_quality_measures._uamcc_int_outcome_exclusion]
cms_quality_measures__uamcc_int_planned_admission[cms_quality_measures._uamcc_int_planned_admission] --> cms_quality_measures__uamcc_int_outcome_exclusion[cms_quality_measures._uamcc_int_outcome_exclusion]
cms_quality_measures__uamcc_value_set_exclusions[cms_quality_measures._uamcc_value_set_exclusions] --> cms_quality_measures__uamcc_int_outcome_exclusion[cms_quality_measures._uamcc_int_outcome_exclusion]
cms_quality_measures__uamcc_value_set_ccs_icd10_cm[cms_quality_measures._uamcc_value_set_ccs_icd10_cm] --> cms_quality_measures__uamcc_int_outcome_exclusion[cms_quality_measures._uamcc_int_outcome_exclusion]
cms_quality_measures__uamcc_int_denominator[cms_quality_measures._uamcc_int_denominator] --> cms_quality_measures__uamcc_int_person_time[cms_quality_measures._uamcc_int_person_time]
core_encounter[core.encounter] --> cms_quality_measures__uamcc_int_person_time[cms_quality_measures._uamcc_int_person_time]
cms_quality_measures__uamcc_performance_period[cms_quality_measures._uamcc_performance_period] --> cms_quality_measures__uamcc_int_person_time[cms_quality_measures._uamcc_int_person_time]
cms_quality_measures__stg_medical_claim[cms_quality_measures._stg_medical_claim] --> cms_quality_measures__uamcc_int_planned_admission[cms_quality_measures._uamcc_int_planned_admission]
cms_quality_measures__uamcc_value_set_paa1[cms_quality_measures._uamcc_value_set_paa1] --> cms_quality_measures__uamcc_int_planned_admission[cms_quality_measures._uamcc_int_planned_admission]
cms_quality_measures__uamcc_value_set_paa2[cms_quality_measures._uamcc_value_set_paa2] --> cms_quality_measures__uamcc_int_planned_admission[cms_quality_measures._uamcc_int_planned_admission]
cms_quality_measures__uamcc_value_set_paa3[cms_quality_measures._uamcc_value_set_paa3] --> cms_quality_measures__uamcc_int_planned_admission[cms_quality_measures._uamcc_int_planned_admission]
cms_quality_measures__uamcc_value_set_paa4[cms_quality_measures._uamcc_value_set_paa4] --> cms_quality_measures__uamcc_int_planned_admission[cms_quality_measures._uamcc_int_planned_admission]
cms_quality_measures__uamcc_value_set_ccs_icd10_cm[cms_quality_measures._uamcc_value_set_ccs_icd10_cm] --> cms_quality_measures__uamcc_int_planned_admission[cms_quality_measures._uamcc_int_planned_admission]
cms_quality_measures__uamcc_value_set_ccs_icd10_pcs[cms_quality_measures._uamcc_value_set_ccs_icd10_pcs] --> cms_quality_measures__uamcc_int_planned_admission[cms_quality_measures._uamcc_int_planned_admission]
cms_quality_measures__uamcc_performance_period[cms_quality_measures._uamcc_performance_period] --> cms_quality_measures__uamcc_performance_period[cms_quality_measures._uamcc_performance_period]
cms_quality_measures__acr_int_index_admission[cms_quality_measures._acr_int_index_admission] --> cms_quality_measures_acr_summary[cms_quality_measures.acr_summary]
cms_quality_measures__acr_int_planned_readmission[cms_quality_measures._acr_int_planned_readmission] --> cms_quality_measures_acr_summary[cms_quality_measures.acr_summary]
cms_quality_measures__acr_performance_period[cms_quality_measures._acr_performance_period] --> cms_quality_measures_acr_summary[cms_quality_measures.acr_summary]
cms_quality_measures__hwr_int_denominator[cms_quality_measures._hwr_int_denominator] --> cms_quality_measures_hwr_summary[cms_quality_measures.hwr_summary]
cms_quality_measures__hwr_int_planned_readmission[cms_quality_measures._hwr_int_planned_readmission] --> cms_quality_measures_hwr_summary[cms_quality_measures.hwr_summary]
cms_quality_measures__hwr_performance_period[cms_quality_measures._hwr_performance_period] --> cms_quality_measures_hwr_summary[cms_quality_measures.hwr_summary]
cms_quality_measures__uamcc_int_numerator[cms_quality_measures._uamcc_int_numerator] --> cms_quality_measures_uamcc_summary[cms_quality_measures.uamcc_summary]
cms_quality_measures__uamcc_int_person_time[cms_quality_measures._uamcc_int_person_time] --> cms_quality_measures_uamcc_summary[cms_quality_measures.uamcc_summary]
cms_quality_measures__uamcc_int_denominator[cms_quality_measures._uamcc_int_denominator] --> cms_quality_measures_uamcc_summary[cms_quality_measures.uamcc_summary]
cms_quality_measures__uamcc_performance_period[cms_quality_measures._uamcc_performance_period] --> cms_quality_measures_uamcc_summary[cms_quality_measures.uamcc_summary]
claims_preprocessing_member_months[claims_preprocessing.member_months] --> core__stg_claims_member_months[core._stg_claims_member_months]
input_layer_input_layer__provider_attribution[input_layer.input_layer__provider_attribution] --> core__stg_claims_member_months[core._stg_claims_member_months]
input_layer_input_layer__appointment[input_layer.input_layer__appointment] --> core__stg_clinical_appointment[core._stg_clinical_appointment]
input_layer_input_layer__condition[input_layer.input_layer__condition] --> core__stg_clinical_condition[core._stg_clinical_condition]
input_layer_input_layer__encounter[input_layer.input_layer__encounter] --> core__stg_clinical_encounter[core._stg_clinical_encounter]
input_layer_input_layer__immunization[input_layer.input_layer__immunization] --> core__stg_clinical_immunization[core._stg_clinical_immunization]
input_layer_input_layer__lab_result[input_layer.input_layer__lab_result] --> core__stg_clinical_lab_result[core._stg_clinical_lab_result]
input_layer_input_layer__location[input_layer.input_layer__location] --> core__stg_clinical_location[core._stg_clinical_location]
input_layer_input_layer__medication[input_layer.input_layer__medication] --> core__stg_clinical_medication[core._stg_clinical_medication]
input_layer_input_layer__observation[input_layer.input_layer__observation] --> core__stg_clinical_observation[core._stg_clinical_observation]
input_layer_input_layer__patient[input_layer.input_layer__patient] --> core__stg_clinical_patient[core._stg_clinical_patient]
input_layer_input_layer__practitioner[input_layer.input_layer__practitioner] --> core__stg_clinical_practitioner[core._stg_clinical_practitioner]
input_layer_input_layer__procedure[input_layer.input_layer__procedure] --> core__stg_clinical_procedure[core._stg_clinical_procedure]
main_dbt_tests[main.dbt_tests] --> data_quality_testing_summary[data_quality.testing_summary]
main_elementary_test_results[main.elementary_test_results] --> data_quality_testing_summary[data_quality.testing_summary]
main_dbt_invocations[main.dbt_invocations] --> data_quality_testing_summary[data_quality.testing_summary]
core_condition[core.condition] --> hcc_suspecting__stg_condition[hcc_suspecting._stg_condition]
core_lab_result[core.lab_result] --> hcc_suspecting__stg_lab_result[hcc_suspecting._stg_lab_result]
core_medication[core.medication] --> hcc_suspecting__stg_medication[hcc_suspecting._stg_medication]
core_observation[core.observation] --> hcc_suspecting__stg_observation[hcc_suspecting._stg_observation]
core_patient[core.patient] --> hcc_suspecting__stg_patient[hcc_suspecting._stg_patient]
core_pharmacy_claim[core.pharmacy_claim] --> hcc_suspecting__stg_pharmacy_claim[hcc_suspecting._stg_pharmacy_claim]
input_layer_appointment[input_layer.appointment] --> input_layer_input_layer__appointment[input_layer.input_layer__appointment]
input_layer_condition[input_layer.condition] --> input_layer_input_layer__condition[input_layer.input_layer__condition]
input_layer_eligibility[input_layer.eligibility] --> input_layer_input_layer__eligibility[input_layer.input_layer__eligibility]
input_layer_encounter[input_layer.encounter] --> input_layer_input_layer__encounter[input_layer.input_layer__encounter]
input_layer_immunization[input_layer.immunization] --> input_layer_input_layer__immunization[input_layer.input_layer__immunization]
input_layer_lab_result[input_layer.lab_result] --> input_layer_input_layer__lab_result[input_layer.input_layer__lab_result]
input_layer_medical_claim[input_layer.medical_claim] --> input_layer_input_layer__medical_claim[input_layer.input_layer__medical_claim]
input_layer_medication[input_layer.medication] --> input_layer_input_layer__medication[input_layer.input_layer__medication]
input_layer_observation[input_layer.observation] --> input_layer_input_layer__observation[input_layer.input_layer__observation]
input_layer_patient[input_layer.patient] --> input_layer_input_layer__patient[input_layer.input_layer__patient]
input_layer_pharmacy_claim[input_layer.pharmacy_claim] --> input_layer_input_layer__pharmacy_claim[input_layer.input_layer__pharmacy_claim]
input_layer_practitioner[input_layer.practitioner] --> input_layer_input_layer__practitioner[input_layer.input_layer__practitioner]
input_layer_provider_attribution[input_layer.provider_attribution] --> input_layer_input_layer__provider_attribution[input_layer.input_layer__provider_attribution]
main_elementary_test_results[main.elementary_test_results] --> main_alerts_anomaly_detection[main.alerts_anomaly_detection]
main_model_run_results[main.model_run_results] --> main_alerts_dbt_models[main.alerts_dbt_models]
main_snapshot_run_results[main.snapshot_run_results] --> main_alerts_dbt_models[main.alerts_dbt_models]
main_dbt_source_freshness_results[main.dbt_source_freshness_results] --> main_alerts_dbt_source_freshness[main.alerts_dbt_source_freshness]
main_dbt_sources[main.dbt_sources] --> main_alerts_dbt_source_freshness[main.alerts_dbt_source_freshness]
main_elementary_test_results[main.elementary_test_results] --> main_alerts_dbt_tests[main.alerts_dbt_tests]
main_elementary_test_results[main.elementary_test_results] --> main_alerts_schema_changes[main.alerts_schema_changes]
main_metrics_anomaly_score[main.metrics_anomaly_score] --> main_anomaly_threshold_sensitivity[main.anomaly_threshold_sensitivity]
main_dbt_models[main.dbt_models] --> main_dbt_artifacts_hashes[main.dbt_artifacts_hashes]
main_dbt_tests[main.dbt_tests] --> main_dbt_artifacts_hashes[main.dbt_artifacts_hashes]
main_dbt_sources[main.dbt_sources] --> main_dbt_artifacts_hashes[main.dbt_artifacts_hashes]
main_dbt_snapshots[main.dbt_snapshots] --> main_dbt_artifacts_hashes[main.dbt_artifacts_hashes]
main_dbt_metrics[main.dbt_metrics] --> main_dbt_artifacts_hashes[main.dbt_artifacts_hashes]
main_dbt_exposures[main.dbt_exposures] --> main_dbt_artifacts_hashes[main.dbt_artifacts_hashes]
main_dbt_seeds[main.dbt_seeds] --> main_dbt_artifacts_hashes[main.dbt_artifacts_hashes]
main_dbt_columns[main.dbt_columns] --> main_dbt_artifacts_hashes[main.dbt_artifacts_hashes]
hcc_suspecting__int_patient_hcc_history[hcc_suspecting._int_patient_hcc_history] --> main_hcc_suspecting__list_all[main.hcc_suspecting__list_all]
hcc_suspecting__int_comorbidity_suspects[hcc_suspecting._int_comorbidity_suspects] --> main_hcc_suspecting__list_all[main.hcc_suspecting__list_all]
hcc_suspecting__int_observation_suspects[hcc_suspecting._int_observation_suspects] --> main_hcc_suspecting__list_all[main.hcc_suspecting__list_all]
hcc_suspecting__int_lab_suspects[hcc_suspecting._int_lab_suspects] --> main_hcc_suspecting__list_all[main.hcc_suspecting__list_all]
hcc_suspecting__int_medication_suspects[hcc_suspecting._int_medication_suspects] --> main_hcc_suspecting__list_all[main.hcc_suspecting__list_all]
main_dbt_invocations[main.dbt_invocations] --> main_job_run_results[main.job_run_results]
main_data_monitoring_metrics[main.data_monitoring_metrics] --> main_metrics_anomaly_score[main.metrics_anomaly_score]
main_dbt_models[main.dbt_models] --> main_model_run_results[main.model_run_results]
main_dbt_run_results[main.dbt_run_results] --> main_model_run_results[main.model_run_results]
main_data_monitoring_metrics[main.data_monitoring_metrics] --> main_monitors_runs[main.monitors_runs]
main_dbt_run_results[main.dbt_run_results] --> main_seed_run_results[main.seed_run_results]
main_dbt_seeds[main.dbt_seeds] --> main_seed_run_results[main.seed_run_results]
main_dbt_run_results[main.dbt_run_results] --> main_snapshot_run_results[main.snapshot_run_results]
main_dbt_snapshots[main.dbt_snapshots] --> main_snapshot_run_results[main.snapshot_run_results]
pharmacy_rxnorm_generic_available[pharmacy.rxnorm_generic_available] --> pharmacy__int_brand_with_generic_available[pharmacy._int_brand_with_generic_available]
core_pharmacy_claim[core.pharmacy_claim] --> pharmacy__int_claims_current_cost[pharmacy._int_claims_current_cost]
pharmacy__int_brand_with_generic_available[pharmacy._int_brand_with_generic_available] --> pharmacy__int_claims_current_cost[pharmacy._int_claims_current_cost]
terminology_ndc[terminology.ndc] --> pharmacy__int_claims_current_cost[pharmacy._int_claims_current_cost]
terminology_rxnorm_brand_generic[terminology.rxnorm_brand_generic] --> pharmacy__int_claims_current_cost[pharmacy._int_claims_current_cost]
pharmacy__int_claims_current_cost[pharmacy._int_claims_current_cost] --> pharmacy__int_generic_cost[pharmacy._int_generic_cost]
pharmacy_rxnorm_generic_available[pharmacy.rxnorm_generic_available] --> pharmacy__int_generic_cost[pharmacy._int_generic_cost]
pharmacy__int_claims_current_cost[pharmacy._int_claims_current_cost] --> pharmacy__int_generic_cost_by_ndc[pharmacy._int_generic_cost_by_ndc]
pharmacy_rxnorm_generic_available[pharmacy.rxnorm_generic_available] --> pharmacy__int_generic_cost_by_ndc[pharmacy._int_generic_cost_by_ndc]
provider_attribution__int_primary_care_claims[provider_attribution._int_primary_care_claims] --> provider_attribution__int_current_steps[provider_attribution._int_current_steps]
provider_attribution__int_provider_classification[provider_attribution._int_provider_classification] --> provider_attribution__int_current_steps[provider_attribution._int_current_steps]
provider_attribution__stg_core__medical_claim[provider_attribution._stg_core__medical_claim] --> provider_attribution__int_current_steps[provider_attribution._int_current_steps]
provider_attribution__stg_core__member_months[provider_attribution._stg_core__member_months] --> provider_attribution__int_current_steps[provider_attribution._int_current_steps]
provider_attribution__stg_reference_data__calendar[provider_attribution._stg_reference_data__calendar] --> provider_attribution__int_current_steps[provider_attribution._int_current_steps]
provider_attribution__stg_terminology__provider[provider_attribution._stg_terminology__provider] --> provider_attribution__int_current_steps[provider_attribution._int_current_steps]
provider_attribution__stg_core__member_months[provider_attribution._stg_core__member_months] --> provider_attribution__int_person_years[provider_attribution._int_person_years]
provider_attribution__stg_core__medical_claim[provider_attribution._stg_core__medical_claim] --> provider_attribution__int_primary_care_claims[provider_attribution._int_primary_care_claims]
provider_attribution__stg_core__member_months[provider_attribution._stg_core__member_months] --> provider_attribution__int_primary_care_claims[provider_attribution._int_primary_care_claims]
provider_attribution__stg_reference_data__calendar[provider_attribution._stg_reference_data__calendar] --> provider_attribution__int_primary_care_claims[provider_attribution._int_primary_care_claims]
provider_attribution__stg_terminology__provider[provider_attribution._stg_terminology__provider] --> provider_attribution__int_primary_care_claims[provider_attribution._int_primary_care_claims]
provider_attribution__int_provider_classification[provider_attribution._int_provider_classification] --> provider_attribution__int_primary_care_claims[provider_attribution._int_primary_care_claims]
cms_provider_attribution__primary_care_hcpcs_codes[cms_provider_attribution._primary_care_hcpcs_codes] --> provider_attribution__int_primary_care_claims[provider_attribution._int_primary_care_claims]
provider_attribution__stg_terminology__provider[provider_attribution._stg_terminology__provider] --> provider_attribution__int_provider_classification[provider_attribution._int_provider_classification]
terminology_medicare_provider_and_supplier_taxonomy_crosswalk[terminology.medicare_provider_and_supplier_taxonomy_crosswalk] --> provider_attribution__int_provider_classification[provider_attribution._int_provider_classification]
cms_provider_attribution__provider_specialty_assignment_codes[cms_provider_attribution._provider_specialty_assignment_codes] --> provider_attribution__int_provider_classification[provider_attribution._int_provider_classification]
provider_attribution__int_person_years[provider_attribution._int_person_years] --> provider_attribution__int_yearly_steps[provider_attribution._int_yearly_steps]
provider_attribution__int_primary_care_claims[provider_attribution._int_primary_care_claims] --> provider_attribution__int_yearly_steps[provider_attribution._int_yearly_steps]
provider_attribution__int_provider_classification[provider_attribution._int_provider_classification] --> provider_attribution__int_yearly_steps[provider_attribution._int_yearly_steps]
provider_attribution__stg_core__medical_claim[provider_attribution._stg_core__medical_claim] --> provider_attribution__int_yearly_steps[provider_attribution._int_yearly_steps]
provider_attribution__stg_core__member_months[provider_attribution._stg_core__member_months] --> provider_attribution__int_yearly_steps[provider_attribution._int_yearly_steps]
provider_attribution__stg_reference_data__calendar[provider_attribution._stg_reference_data__calendar] --> provider_attribution__int_yearly_steps[provider_attribution._int_yearly_steps]
provider_attribution__stg_terminology__provider[provider_attribution._stg_terminology__provider] --> provider_attribution__int_yearly_steps[provider_attribution._int_yearly_steps]
core__stg_claims_medical_claim[core._stg_claims_medical_claim] --> provider_attribution__stg_core__claims_medical_claim[provider_attribution._stg_core__claims_medical_claim]
core_medical_claim[core.medical_claim] --> provider_attribution__stg_core__medical_claim[provider_attribution._stg_core__medical_claim]
core_member_months[core.member_months] --> provider_attribution__stg_core__member_months[provider_attribution._stg_core__member_months]
reference_data_calendar[reference_data.calendar] --> provider_attribution__stg_reference_data__calendar[provider_attribution._stg_reference_data__calendar]
terminology_provider[terminology.provider] --> provider_attribution__stg_terminology__provider[provider_attribution._stg_terminology__provider]
quality_measures__value_set_measures[quality_measures._value_set_measures] --> quality_measures__int_adh_diabetes__performance_period[quality_measures._int_adh_diabetes__performance_period]
quality_measures__value_set_measures[quality_measures._value_set_measures] --> quality_measures__int_adh_statins__performance_period[quality_measures._int_adh_statins__performance_period]
quality_measures__value_set_measures[quality_measures._value_set_measures] --> quality_measures__int_adhras__performance_period[quality_measures._int_adhras__performance_period]
quality_measures__value_set_measures[quality_measures._value_set_measures] --> quality_measures__int_cqm130__performance_period[quality_measures._int_cqm130__performance_period]
quality_measures__value_set_measures[quality_measures._value_set_measures] --> quality_measures__int_cqm438__performance_period[quality_measures._int_cqm438__performance_period]
quality_measures__value_set_measures[quality_measures._value_set_measures] --> quality_measures__int_nqf0420__performance_period[quality_measures._int_nqf0420__performance_period]
quality_measures__value_set_measures[quality_measures._value_set_measures] --> quality_measures__int_supd__performance_period[quality_measures._int_supd__performance_period]
core_condition[core.condition] --> quality_measures__stg_condition[quality_measures._stg_condition]
core_encounter[core.encounter] --> quality_measures__stg_encounter[quality_measures._stg_encounter]
core_lab_result[core.lab_result] --> quality_measures__stg_lab_result[quality_measures._stg_lab_result]
core_medical_claim[core.medical_claim] --> quality_measures__stg_medical_claim[quality_measures._stg_medical_claim]
core_medication[core.medication] --> quality_measures__stg_medication[quality_measures._stg_medication]
core_observation[core.observation] --> quality_measures__stg_observation[quality_measures._stg_observation]
core_patient[core.patient] --> quality_measures__stg_patient[quality_measures._stg_patient]
core_pharmacy_claim[core.pharmacy_claim] --> quality_measures__stg_pharmacy_claim[quality_measures._stg_pharmacy_claim]
core_encounter[core.encounter] --> readmissions__int_encounter[readmissions._int_encounter]
readmissions__int_encounter_with_ccs[readmissions._int_encounter_with_ccs] --> readmissions__int_encounter_data_quality[readmissions._int_encounter_data_quality]
readmissions__int_encounter_overlap[readmissions._int_encounter_overlap] --> readmissions__int_encounter_data_quality[readmissions._int_encounter_data_quality]
terminology_discharge_disposition[terminology.discharge_disposition] --> readmissions__int_encounter_data_quality[readmissions._int_encounter_data_quality]
terminology_ms_drg[terminology.ms_drg] --> readmissions__int_encounter_data_quality[readmissions._int_encounter_data_quality]
terminology_apr_drg[terminology.apr_drg] --> readmissions__int_encounter_data_quality[readmissions._int_encounter_data_quality]
readmissions__int_encounter[readmissions._int_encounter] --> readmissions__int_encounter_overlap[readmissions._int_encounter_overlap]
readmissions__int_encounter[readmissions._int_encounter] --> readmissions__int_encounter_specialty_cohort[readmissions._int_encounter_specialty_cohort]
readmissions__int_encounter_with_ccs[readmissions._int_encounter_with_ccs] --> readmissions__int_encounter_specialty_cohort[readmissions._int_encounter_specialty_cohort]
readmissions__int_procedure_ccs[readmissions._int_procedure_ccs] --> readmissions__int_encounter_specialty_cohort[readmissions._int_encounter_specialty_cohort]
readmissions__value_set_specialty_cohort[readmissions._value_set_specialty_cohort] --> readmissions__int_encounter_specialty_cohort[readmissions._int_encounter_specialty_cohort]
readmissions__value_set_surgery_gynecology_cohort[readmissions._value_set_surgery_gynecology_cohort] --> readmissions__int_encounter_specialty_cohort[readmissions._int_encounter_specialty_cohort]
readmissions__int_encounter[readmissions._int_encounter] --> readmissions__int_encounter_with_ccs[readmissions._int_encounter_with_ccs]
readmissions__value_set_icd_10_cm_to_ccs[readmissions._value_set_icd_10_cm_to_ccs] --> readmissions__int_encounter_with_ccs[readmissions._int_encounter_with_ccs]
terminology_icd_10_cm[terminology.icd_10_cm] --> readmissions__int_encounter_with_ccs[readmissions._int_encounter_with_ccs]
readmissions__int_encounter_with_ccs[readmissions._int_encounter_with_ccs] --> readmissions__int_exclusion[readmissions._int_exclusion]
readmissions__value_set_exclusion_ccs_diagnosis_category[readmissions._value_set_exclusion_ccs_diagnosis_category] --> readmissions__int_exclusion[readmissions._int_exclusion]
readmissions__int_encounter[readmissions._int_encounter] --> readmissions__int_index_admission[readmissions._int_index_admission]
readmissions__int_index_time_requirement[readmissions._int_index_time_requirement] --> readmissions__int_index_admission[readmissions._int_index_admission]
readmissions__int_index_discharge_requirement[readmissions._int_index_discharge_requirement] --> readmissions__int_index_admission[readmissions._int_index_admission]
readmissions__int_exclusion[readmissions._int_exclusion] --> readmissions__int_index_admission[readmissions._int_index_admission]
readmissions__int_encounter[readmissions._int_encounter] --> readmissions__int_index_discharge_requirement[readmissions._int_index_discharge_requirement]
readmissions__int_encounter[readmissions._int_encounter] --> readmissions__int_index_time_requirement[readmissions._int_index_time_requirement]
readmissions__int_encounter_with_ccs[readmissions._int_encounter_with_ccs] --> readmissions__int_planned_encounter[readmissions._int_planned_encounter]
readmissions__int_procedure_ccs[readmissions._int_procedure_ccs] --> readmissions__int_planned_encounter[readmissions._int_planned_encounter]
readmissions__value_set_acute_diagnosis_ccs[readmissions._value_set_acute_diagnosis_ccs] --> readmissions__int_planned_encounter[readmissions._int_planned_encounter]
readmissions__value_set_acute_diagnosis_icd_10_cm[readmissions._value_set_acute_diagnosis_icd_10_cm] --> readmissions__int_planned_encounter[readmissions._int_planned_encounter]
readmissions__value_set_always_planned_ccs_diagnosis_category[readmissions._value_set_always_planned_ccs_diagnosis_category] --> readmissions__int_planned_encounter[readmissions._int_planned_encounter]
readmissions__value_set_always_planned_ccs_procedure_category[readmissions._value_set_always_planned_ccs_procedure_category] --> readmissions__int_planned_encounter[readmissions._int_planned_encounter]
readmissions__value_set_potentially_planned_ccs_procedure_category[readmissions._value_set_potentially_planned_ccs_procedure_category] --> readmissions__int_planned_encounter[readmissions._int_planned_encounter]
readmissions__value_set_potentially_planned_icd_10_pcs[readmissions._value_set_potentially_planned_icd_10_pcs] --> readmissions__int_planned_encounter[readmissions._int_planned_encounter]
core_procedure[core.procedure] --> readmissions__int_procedure_ccs[readmissions._int_procedure_ccs]
readmissions__value_set_icd_10_pcs_to_ccs[readmissions._value_set_icd_10_pcs_to_ccs] --> readmissions__int_procedure_ccs[readmissions._int_procedure_ccs]
terminology_icd_10_pcs[terminology.icd_10_pcs] --> readmissions__int_procedure_ccs[readmissions._int_procedure_ccs]
readmissions__int_encounter[readmissions._int_encounter] --> readmissions__int_readmission_crude[readmissions._int_readmission_crude]
readmissions__int_encounter_overlap[readmissions._int_encounter_overlap] --> readmissions__int_readmission_crude[readmissions._int_readmission_crude]
```

View File

@@ -0,0 +1 @@
{"label": "Pipelines", "position": 12}

View File

@@ -0,0 +1,62 @@
---
title: ahrq_measures
sidebar_position: 2
---
# ahrq_measures
**Steps:** 39
## Steps
1. **ahrq_measures._stg_pqi_inpatient_encounter** — Filter core.encounter to acute inpatient, add year_number.
2. **ahrq_measures._stg_pqi_member_months** — Join member_months with calendar to get first_day_of_month.
3. **ahrq_measures._int_pqi_shared_exclusion_missing_dates** — Encounters with missing start date.
4. **ahrq_measures._int_pqi_shared_exclusion_missing_gender** — Patients with sex not in (male, female).
5. **ahrq_measures._int_pqi_shared_exclusion_missing_primary_dx** — Encounters with missing primary diagnosis.
6. **ahrq_measures._int_pqi_shared_exclusion_transfer** — Encounters admitted via transfer.
7. **ahrq_measures._int_pqi_shared_exclusion_ungroupable_drg** — Encounters with ungroupable DRG (999).
8. **ahrq_measures._int_pqi_shared_exclusions_missing_age** — Patients with missing birth_date.
9. **ahrq_measures._int_pqi_shared_exclusion_union** — Union all shared exclusions, joining person-level ones back
10. **ahrq_measures._int_pqi_01_denom** — Eligible members for PQI 01 (diabetes short-term complications), all ages.
11. **ahrq_measures._int_pqi_01_exclusions** — Shared exclusions only (missing data, transfer, ungroupable DRG).
12. **ahrq_measures._int_pqi_01_num** — Diabetes short-term complications diagnosis, in denom, not excluded.
13. **ahrq_measures._int_pqi_03_denom** — Eligible members for PQI 03 (diabetes long-term complications), all ages.
14. **ahrq_measures._int_pqi_03_exclusions** — Shared exclusions only (missing data, transfer, ungroupable DRG).
15. **ahrq_measures._int_pqi_03_num** — Diabetes long-term complications diagnosis, in denom, not excluded.
16. **ahrq_measures._int_pqi_05_denom** — Eligible members for PQI 05 (COPD/asthma), age >= 40.
17. **ahrq_measures._int_pqi_05_exclusions** — Shared exclusions + cystic fibrosis from conditions.
18. **ahrq_measures._int_pqi_05_num** — COPD or asthma diagnosis, in denom, not excluded.
19. **ahrq_measures._int_pqi_07_denom** — Eligible members for PQI 07 (hypertension), all ages.
20. **ahrq_measures._int_pqi_07_exclusions** — Shared + cardiac procedure + CKD w/ dialysis access.
21. **ahrq_measures._int_pqi_07_num** — Hypertension diagnosis, in denom, not excluded.
22. **ahrq_measures._int_pqi_08_denom** — Eligible members for PQI 08 (heart failure), all ages.
23. **ahrq_measures._int_pqi_08_exclusions** — Shared + cardiac procedure.
24. **ahrq_measures._int_pqi_08_num** — Heart failure diagnosis, in denom, not excluded.
25. **ahrq_measures._int_pqi_11_denom** — Eligible members for PQI 11 (bacterial pneumonia), all ages.
26. **ahrq_measures._int_pqi_11_exclusions** — Shared + sickle cell + immunocompromised dx/px.
27. **ahrq_measures._int_pqi_11_num** — Community-acquired bacterial pneumonia diagnosis, in denom, not excluded.
28. **ahrq_measures._int_pqi_12_denom** — Eligible members for PQI 12 (urinary tract infection), all ages.
29. **ahrq_measures._int_pqi_12_exclusions** — Shared + kidney + immunocompromised dx/px.
30. **ahrq_measures._int_pqi_12_num** — Urinary tract infection diagnosis, in denom, not excluded.
31. **ahrq_measures._int_pqi_14_denom** — Eligible members for PQI 14 (uncontrolled diabetes), all ages.
32. **ahrq_measures._int_pqi_14_exclusions** — Shared exclusions only (missing data, transfer, ungroupable DRG).
33. **ahrq_measures._int_pqi_14_num** — Uncontrolled diabetes diagnosis, in denom, not excluded.
34. **ahrq_measures._int_pqi_15_denom** — Eligible members for PQI 15 (asthma, younger adults), age 18–39.
35. **ahrq_measures._int_pqi_15_exclusions** — Shared + cystic fibrosis.
36. **ahrq_measures._int_pqi_15_num** — Asthma diagnosis (age 18–39), in denom, not excluded.
37. **ahrq_measures._int_pqi_16_denom** — Eligible members for PQI 16 (lower-extremity amputation), all ages.
38. **ahrq_measures._int_pqi_16_exclusions** — Shared + amputation + pregnancy.
39. **ahrq_measures._int_pqi_16_num** — PQI 16: diabetes dx + lower-extremity amputation px.
## Regulatory References
- [42 CFR Part 405 — Part 405—Federal Health Insurance for the Aged and Disabled](https://www.ecfr.gov/current/title-42/part-405)
- [42 CFR Part 410 — Part 410—Supplementary Medical Insurance (SMI) Benefits](https://www.ecfr.gov/current/title-42/part-410)
- [42 CFR Part 411 — Part 411—Exclusions from Medicare and Limitations on Medicare Payment](https://www.ecfr.gov/current/title-42/part-411)
- [42 CFR Part 414 — Part 414—Payment for Part B Medical and Other Health Services](https://www.ecfr.gov/current/title-42/part-414)
- [42 CFR Part 415 — Part 415—Services Furnished by Physicians in Providers, Supervising Physicians in Teaching Settings, and Residents in Certain Settings](https://www.ecfr.gov/current/title-42/part-415)

View File

@@ -0,0 +1,42 @@
---
title: cclf
sidebar_position: 3
---
# cclf
**Steps:** 19
## Steps
1. **cclf._stg_beneficiary_xref** — Deduplicate CCLF9 to get latest current MBI per previous MBI.
2. **cclf._stg_institutional_header** — Stage CCLF1 with MBI resolution and cancellation adjustment.
3. **cclf._int_institutional_header_adr** — Apply ADR logic to CCLF1: keep latest version, drop cancelled.
4. **cclf._stg_revenue_center** — Stage CCLF2 with MBI resolution.
5. **cclf._int_diagnosis_pivot** — Pivot CCLF4 diagnosis codes from long to wide (25 slots).
6. **cclf._int_procedure_pivot** — Pivot CCLF3 procedure codes from long to wide (25 slots).
7. **cclf._int_institutional_medical_claim** — Join CCLF1 header + CCLF2 lines + CCLF4 dx + CCLF3 px.
8. **cclf._stg_physician_claim** — Stage CCLF5 with MBI resolution and cancellation adjustment.
9. **cclf._int_physician_claim_adr** — ADR for CCLF5: latest version, drop cancelled/denied.
10. **cclf._int_physician_medical_claim** — Map CCLF5 to medical_claim schema (professional).
11. **cclf._stg_dme_claim** — Stage CCLF6 with MBI resolution and cancellation adjustment.
12. **cclf._int_dme_claim_adr** — ADR for CCLF6: latest version, drop cancelled/denied.
13. **cclf._int_dme_medical_claim** — Map CCLF6 to medical_claim schema (professional/DME).
14. **cclf.medical_claim** — Union institutional + professional + DME into medical_claim.
15. **cclf._stg_pharmacy_claim** — Stage CCLF7 with MBI resolution.
16. **cclf._int_pharmacy_claim_adr** — ADR for CCLF7: latest adjustment, drop cancelled.
17. **cclf.pharmacy_claim** — Map CCLF7 to pharmacy_claim schema.
18. **cclf._stg_beneficiary_demographics** — Stage CCLF8 with MBI resolution and dedup.
19. **cclf.eligibility** — Map CCLF8 to eligibility schema with value crosswalks.
## Regulatory References
- [42 CFR Part 405 — Part 405—Federal Health Insurance for the Aged and Disabled](https://www.ecfr.gov/current/title-42/part-405)
- [42 CFR Part 410 — Part 410—Supplementary Medical Insurance (SMI) Benefits](https://www.ecfr.gov/current/title-42/part-410)
- [42 CFR Part 411 — Part 411—Exclusions from Medicare and Limitations on Medicare Payment](https://www.ecfr.gov/current/title-42/part-411)
- [42 CFR Part 414 — Part 414—Payment for Part B Medical and Other Health Services](https://www.ecfr.gov/current/title-42/part-414)
- [42 CFR Part 415 — Part 415—Services Furnished by Physicians in Providers, Supervising Physicians in Teaching Settings, and Residents in Certain Settings](https://www.ecfr.gov/current/title-42/part-415)

View File

@@ -0,0 +1,86 @@
---
title: claims_preprocessing
sidebar_position: 4
---
# claims_preprocessing
**Steps:** 63
## Steps
1. **claims_preprocessing.service_category__stg_medical_claim** — Build claims_preprocessing.service_category__stg_medical_claim
2. **claims_preprocessing.service_category__stg_professional** — Build claims_preprocessing.service_category__stg_professional
3. **claims_preprocessing.service_category__stg_inpatient_institutional** — Build claims_preprocessing.service_category__stg_inpatient_institutional
4. **claims_preprocessing.service_category__stg_outpatient_institutional** — Build claims_preprocessing.service_category__stg_outpatient_institutional
5. **claims_preprocessing.service_category__stg_office_based** — Build claims_preprocessing.service_category__stg_office_based
6. **claims_preprocessing.service_category__dme_institutional** — Build claims_preprocessing.service_category__dme_institutional
7. **claims_preprocessing.service_category__inpatient_substance_use_professional** — Build claims_preprocessing.service_category__inpatient_substance_use_professional
8. **claims_preprocessing.service_category__outpatient_skilled_nursing_institutional** — Build claims_preprocessing
9. **claims_preprocessing.ambulance__anchor_events** — Build claims_preprocessing.ambulance__anchor_events
10. **claims_preprocessing.ambulance__generate_encounter_id** — Rejoin anchor with stg_medical_claim, assign encounter ids.
11. **claims_preprocessing.ambulance__match_claims_to_anchor** — Join stg_medical_claim with generate_encounter_id.
12. **claims_preprocessing.asc__anchor_events** — Build claims_preprocessing.asc__anchor_events
13. **claims_preprocessing.asc__generate_encounter_id** — Window-based encounter grouping for ASC encounters.
14. **claims_preprocessing.asc__start_end_dates** — Group generate_encounter_id by patient + encounter to get date range.
15. **claims_preprocessing.asc__match_claims_to_anchor** — Join stg_medical_claim with start_end_dates on patient + date range.
16. **claims_preprocessing.dialysis__anchor_events** — Build claims_preprocessing.dialysis__anchor_events
17. **claims_preprocessing.dialysis__generate_encounter_id** — Rejoin anchor with stg_medical_claim, assign encounter ids.
18. **claims_preprocessing.dialysis__match_claims_to_anchor** — Join stg_medical_claim with generate_encounter_id.
19. **claims_preprocessing.dme__anchor_events** — Build claims_preprocessing.dme__anchor_events
20. **claims_preprocessing.dme__generate_encounter_id** — Rejoin anchor with stg_medical_claim, assign encounter ids.
21. **claims_preprocessing.dme__match_claims_to_anchor** — Join stg_medical_claim with generate_encounter_id.
22. **claims_preprocessing.home_health__anchor_events** — Build claims_preprocessing.home_health__anchor_events
23. **claims_preprocessing.home_health__generate_encounter_id** — Rejoin anchor with stg_medical_claim, assign encounter ids.
24. **claims_preprocessing.home_health__match_claims_to_anchor** — Join stg_medical_claim with generate_encounter_id.
25. **claims_preprocessing.lab__anchor_events** — Build claims_preprocessing.lab__anchor_events
26. **claims_preprocessing.lab__generate_encounter_id** — Rejoin anchor with stg_medical_claim, assign encounter ids.
27. **claims_preprocessing.lab__match_claims_to_anchor** — Join stg_medical_claim with generate_encounter_id.
28. **claims_preprocessing.outpatient_hospice__anchor_events** — Build claims_preprocessing.outpatient_hospice__anchor_events
29. **claims_preprocessing.outpatient_hospice__generate_encounter_id** — Rejoin anchor with stg_medical_claim, assign encounter ids.
30. **claims_preprocessing.outpatient_hospice__match_claims_to_anchor** — Join stg_medical_claim with generate_encounter_id.
31. **claims_preprocessing.outpatient_hospital_or_clinic__anchor_events** — Build claims_preprocessing.outpatient_hospital_or_clinic__anchor_events
32. **claims_preprocessing.outpatient_hospital_or_clinic__generate_encounter_id** — Rejoin anchor with stg_medical_claim, assign encounter ids.
33. **claims_preprocessing.outpatient_hospital_or_clinic__match_claims_to_anchor** — Join stg_medical_claim with generate_encounter_id.
34. **claims_preprocessing.outpatient_injections__anchor_events** — Build claims_preprocessing.outpatient_injections__anchor_events
35. **claims_preprocessing.outpatient_injections__generate_encounter_id** — Build claims_preprocessing.outpatient_injections__generate_encounter_id
36. **claims_preprocessing.outpatient_injections__match_claims_to_anchor** — Join stg_medical_claim with generate_encounter_id.
37. **claims_preprocessing.outpatient_psych__anchor_events** — Build claims_preprocessing.outpatient_psych__anchor_events
38. **claims_preprocessing.outpatient_psych__generate_encounter_id** — Rejoin anchor with stg_medical_claim, assign encounter ids.
39. **claims_preprocessing.outpatient_psych__match_claims_to_anchor** — Join stg_medical_claim with generate_encounter_id.
40. **claims_preprocessing.outpatient_ptotst__anchor_events** — Build claims_preprocessing.outpatient_ptotst__anchor_events
41. **claims_preprocessing.outpatient_ptotst__generate_encounter_id** — Rejoin anchor with stg_medical_claim, assign encounter ids.
42. **claims_preprocessing.outpatient_ptotst__match_claims_to_anchor** — Join stg_medical_claim with generate_encounter_id.
43. **claims_preprocessing.outpatient_radiology__anchor_events** — Build claims_preprocessing.outpatient_radiology__anchor_events
44. **claims_preprocessing.outpatient_radiology__generate_encounter_id** — Build claims_preprocessing.outpatient_radiology__generate_encounter_id
45. **claims_preprocessing.outpatient_radiology__match_claims_to_anchor** — Join stg_medical_claim with generate_encounter_id on patient+date+hcpcs.
46. **claims_preprocessing.outpatient_rehab__anchor_events** — Build claims_preprocessing.outpatient_rehab__anchor_events
47. **claims_preprocessing.outpatient_rehab__generate_encounter_id** — Rejoin anchor with stg_medical_claim, assign encounter ids.
48. **claims_preprocessing.outpatient_rehab__match_claims_to_anchor** — Join stg_medical_claim with generate_encounter_id.
49. **claims_preprocessing.outpatient_substance_use__anchor_events** — Build claims_preprocessing.outpatient_substance_use__anchor_events
50. **claims_preprocessing.outpatient_substance_use__generate_encounter_id** — Rejoin anchor with stg_medical_claim, assign encounter ids.
51. **claims_preprocessing.outpatient_substance_use__match_claims_to_anchor** — Join stg_medical_claim with generate_encounter_id.
52. **claims_preprocessing.outpatient_surgery__anchor_events** — Build claims_preprocessing.outpatient_surgery__anchor_events
53. **claims_preprocessing.outpatient_surgery__generate_encounter_id** — Rejoin anchor with stg_medical_claim, assign encounter ids.
54. **claims_preprocessing.outpatient_surgery__match_claims_to_anchor** — Join stg_medical_claim with generate_encounter_id.
55. **claims_preprocessing.urgent_care__anchor_events** — Build claims_preprocessing.urgent_care__anchor_events
56. **claims_preprocessing.urgent_care__generate_encounter_id** — Rejoin anchor with stg_medical_claim, assign encounter ids.
57. **claims_preprocessing.urgent_care__match_claims_to_anchor** — Join stg_medical_claim with generate_encounter_id.
58. **claims_preprocessing.office_visits__int_office_visits_injections** — Build claims_preprocessing.office_visits__int_office_visits_injections
59. **claims_preprocessing.office_visits__int_office_visits_ptotst** — Build claims_preprocessing.office_visits__int_office_visits_ptotst
60. **claims_preprocessing.office_visits__int_office_visits_radiology** — Build claims_preprocessing.office_visits__int_office_visits_radiology
61. **claims_preprocessing.office_visits__int_office_visits_surgery** — Build claims_preprocessing.office_visits__int_office_visits_surgery
62. **claims_preprocessing.office_visits__int_office_visits_telehealth** — Build claims_preprocessing.office_visits__int_office_visits_telehealth
63. **claims_preprocessing.encounters__orphaned_claims** — Build claims_preprocessing.encounters__orphaned_claims
## Regulatory References
- [42 CFR Part 405 — Part 405—Federal Health Insurance for the Aged and Disabled](https://www.ecfr.gov/current/title-42/part-405)
- [42 CFR Part 410 — Part 410—Supplementary Medical Insurance (SMI) Benefits](https://www.ecfr.gov/current/title-42/part-410)
- [42 CFR Part 411 — Part 411—Exclusions from Medicare and Limitations on Medicare Payment](https://www.ecfr.gov/current/title-42/part-411)
- [42 CFR Part 414 — Part 414—Payment for Part B Medical and Other Health Services](https://www.ecfr.gov/current/title-42/part-414)
- [42 CFR Part 415 — Part 415—Services Furnished by Physicians in Providers, Supervising Physicians in Teaching Settings, and Residents in Certain Settings](https://www.ecfr.gov/current/title-42/part-415)

View File

@@ -0,0 +1,43 @@
---
title: cms_quality_measures
sidebar_position: 5
---
# cms_quality_measures
**Steps:** 20
## Steps
1. **cms_quality_measures._stg_medical_claim** — Stage medical claims with the principal diagnosis code.
2. **cms_quality_measures._stg_medical_claim_condition** — Stage medical claims joined with all condition diagnosis codes.
3. **cms_quality_measures._uamcc_performance_period** — Return the UAMCC performance period anchor row.
4. **cms_quality_measures._uamcc_int_mcc_cohort** — Identify each beneficiary's qualifying chronic condition groups.
5. **cms_quality_measures._uamcc_int_denominator** — Build the UAMCC denominator: MCC-eligible beneficiaries aged ≥66.
6. **cms_quality_measures._uamcc_int_denominator_exclusion** — Identify beneficiaries excluded from the UAMCC denominator.
7. **cms_quality_measures._uamcc_int_planned_admission** — Apply PAA v4.0 2024 to classify inpatient admissions as planned.
8. **cms_quality_measures._uamcc_int_outcome_exclusion** — Flag inpatient admissions excluded from the UAMCC outcome.
9. **cms_quality_measures._uamcc_int_person_time** — Calculate at-risk person-time for each UAMCC-eligible beneficiary.
10. **cms_quality_measures._uamcc_int_numerator** — Identify qualifying unplanned acute admissions for the UAMCC outcome.
11. **cms_quality_measures.uamcc_summary** — Compute ACO-level UAMCC observed admission rate per 100 person-years.
12. **cms_quality_measures._acr_performance_period** — Return the ACR performance period anchor row.
13. **cms_quality_measures._acr_int_index_admission** — Identify eligible index hospitalizations for the ACR denominator.
14. **cms_quality_measures._acr_int_specialty_cohort** — Assign each ACR index admission to a specialty cohort.
15. **cms_quality_measures._acr_int_planned_readmission** — Apply PAA v4.0 to classify candidate readmissions for ACR.
16. **cms_quality_measures.acr_summary** — Compute ACO-level ACR observed readmission rate.
17. **cms_quality_measures._hwr_performance_period** — Return the MIPS HWR performance period anchor row.
18. **cms_quality_measures._hwr_int_denominator** — Build the MIPS HWR denominator: eligible index hospitalizations.
19. **cms_quality_measures._hwr_int_planned_readmission** — Apply PAA v4.0 to classify candidate readmissions for MIPS HWR.
20. **cms_quality_measures.hwr_summary** — Compute MIPS clinician group HWR observed readmission rate.
## Regulatory References
- [42 CFR Part 405 — Part 405—Federal Health Insurance for the Aged and Disabled](https://www.ecfr.gov/current/title-42/part-405)
- [42 CFR Part 410 — Part 410—Supplementary Medical Insurance (SMI) Benefits](https://www.ecfr.gov/current/title-42/part-410)
- [42 CFR Part 411 — Part 411—Exclusions from Medicare and Limitations on Medicare Payment](https://www.ecfr.gov/current/title-42/part-411)
- [42 CFR Part 414 — Part 414—Payment for Part B Medical and Other Health Services](https://www.ecfr.gov/current/title-42/part-414)
- [42 CFR Part 415 — Part 415—Services Furnished by Physicians in Providers, Supervising Physicians in Teaching Settings, and Residents in Certain Settings](https://www.ecfr.gov/current/title-42/part-415)

View File

@@ -0,0 +1,35 @@
---
title: core
sidebar_position: 6
---
# core
**Steps:** 12
## Steps
1. **core._stg_claims_member_months** — Build core._stg_claims_member_months
2. **core._stg_clinical_appointment** — Build core._stg_clinical_appointment
3. **core._stg_clinical_condition** — Build core._stg_clinical_condition
4. **core._stg_clinical_encounter** — Build core._stg_clinical_encounter
5. **core._stg_clinical_immunization** — Build core._stg_clinical_immunization
6. **core._stg_clinical_lab_result** — Build core._stg_clinical_lab_result
7. **core._stg_clinical_location** — Build core._stg_clinical_location
8. **core._stg_clinical_medication** — Build core._stg_clinical_medication
9. **core._stg_clinical_observation** — Build core._stg_clinical_observation
10. **core._stg_clinical_patient** — Build core._stg_clinical_patient
11. **core._stg_clinical_practitioner** — Build core._stg_clinical_practitioner
12. **core._stg_clinical_procedure** — Build core._stg_clinical_procedure
## Regulatory References
- [42 CFR Part 405 — Part 405—Federal Health Insurance for the Aged and Disabled](https://www.ecfr.gov/current/title-42/part-405)
- [42 CFR Part 410 — Part 410—Supplementary Medical Insurance (SMI) Benefits](https://www.ecfr.gov/current/title-42/part-410)
- [42 CFR Part 411 — Part 411—Exclusions from Medicare and Limitations on Medicare Payment](https://www.ecfr.gov/current/title-42/part-411)
- [42 CFR Part 414 — Part 414—Payment for Part B Medical and Other Health Services](https://www.ecfr.gov/current/title-42/part-414)
- [42 CFR Part 415 — Part 415—Services Furnished by Physicians in Providers, Supervising Physicians in Teaching Settings, and Residents in Certain Settings](https://www.ecfr.gov/current/title-42/part-415)

View File

@@ -0,0 +1,24 @@
---
title: data_quality
sidebar_position: 7
---
# data_quality
**Steps:** 1
## Steps
1. **data_quality.testing_summary** — Build data_quality.testing_summary
## Regulatory References
- [42 CFR Part 405 — Part 405—Federal Health Insurance for the Aged and Disabled](https://www.ecfr.gov/current/title-42/part-405)
- [42 CFR Part 410 — Part 410—Supplementary Medical Insurance (SMI) Benefits](https://www.ecfr.gov/current/title-42/part-410)
- [42 CFR Part 411 — Part 411—Exclusions from Medicare and Limitations on Medicare Payment](https://www.ecfr.gov/current/title-42/part-411)
- [42 CFR Part 414 — Part 414—Payment for Part B Medical and Other Health Services](https://www.ecfr.gov/current/title-42/part-414)
- [42 CFR Part 415 — Part 415—Services Furnished by Physicians in Providers, Supervising Physicians in Teaching Settings, and Residents in Certain Settings](https://www.ecfr.gov/current/title-42/part-415)

View File

@@ -0,0 +1,29 @@
---
title: hcc_suspecting
sidebar_position: 8
---
# hcc_suspecting
**Steps:** 6
## Steps
1. **hcc_suspecting._stg_condition** — Build hcc_suspecting._stg_condition
2. **hcc_suspecting._stg_lab_result** — Build hcc_suspecting._stg_lab_result
3. **hcc_suspecting._stg_medication** — Build hcc_suspecting._stg_medication
4. **hcc_suspecting._stg_observation** — Build hcc_suspecting._stg_observation
5. **hcc_suspecting._stg_patient** — Build hcc_suspecting._stg_patient
6. **hcc_suspecting._stg_pharmacy_claim** — Build hcc_suspecting._stg_pharmacy_claim
## Regulatory References
- [42 CFR Part 405 — Part 405—Federal Health Insurance for the Aged and Disabled](https://www.ecfr.gov/current/title-42/part-405)
- [42 CFR Part 410 — Part 410—Supplementary Medical Insurance (SMI) Benefits](https://www.ecfr.gov/current/title-42/part-410)
- [42 CFR Part 411 — Part 411—Exclusions from Medicare and Limitations on Medicare Payment](https://www.ecfr.gov/current/title-42/part-411)
- [42 CFR Part 414 — Part 414—Payment for Part B Medical and Other Health Services](https://www.ecfr.gov/current/title-42/part-414)
- [42 CFR Part 415 — Part 415—Services Furnished by Physicians in Providers, Supervising Physicians in Teaching Settings, and Residents in Certain Settings](https://www.ecfr.gov/current/title-42/part-415)

View File

@@ -0,0 +1,22 @@
---
title: Pipelines
sidebar_position: 1
---
# Pipelines
| Pipeline | Steps | Description |
|----------|-------|-------------|
| [ahrq_measures](./ahrq_measures) | 39 | |
| [cclf](./cclf) | 19 | |
| [claims_preprocessing](./claims_preprocessing) | 63 | |
| [cms_quality_measures](./cms_quality_measures) | 20 | |
| [core](./core) | 12 | |
| [data_quality](./data_quality) | 1 | |
| [hcc_suspecting](./hcc_suspecting) | 6 | |
| [input_layer](./input_layer) | 13 | |
| [main](./main) | 14 | |
| [pharmacy](./pharmacy) | 4 | |
| [provider_attribution](./provider_attribution) | 10 | |
| [quality_measures](./quality_measures) | 15 | |
| [readmissions](./readmissions) | 12 | |

View File

@@ -0,0 +1,36 @@
---
title: input_layer
sidebar_position: 9
---
# input_layer
**Steps:** 13
## Steps
1. **input_layer.input_layer__appointment** — Build input_layer.input_layer__appointment
2. **input_layer.input_layer__condition** — Build input_layer.input_layer__condition
3. **input_layer.input_layer__eligibility** — Build input_layer.input_layer__eligibility
4. **input_layer.input_layer__encounter** — Build input_layer.input_layer__encounter
5. **input_layer.input_layer__immunization** — Build input_layer.input_layer__immunization
6. **input_layer.input_layer__lab_result** — Build input_layer.input_layer__lab_result
7. **input_layer.input_layer__medical_claim** — Build input_layer.input_layer__medical_claim
8. **input_layer.input_layer__medication** — Build input_layer.input_layer__medication
9. **input_layer.input_layer__observation** — Build input_layer.input_layer__observation
10. **input_layer.input_layer__patient** — Build input_layer.input_layer__patient
11. **input_layer.input_layer__pharmacy_claim** — Build input_layer.input_layer__pharmacy_claim
12. **input_layer.input_layer__practitioner** — Build input_layer.input_layer__practitioner
13. **input_layer.input_layer__provider_attribution** — Build input_layer.input_layer__provider_attribution
## Regulatory References
- [42 CFR Part 405 — Part 405—Federal Health Insurance for the Aged and Disabled](https://www.ecfr.gov/current/title-42/part-405)
- [42 CFR Part 410 — Part 410—Supplementary Medical Insurance (SMI) Benefits](https://www.ecfr.gov/current/title-42/part-410)
- [42 CFR Part 411 — Part 411—Exclusions from Medicare and Limitations on Medicare Payment](https://www.ecfr.gov/current/title-42/part-411)
- [42 CFR Part 414 — Part 414—Payment for Part B Medical and Other Health Services](https://www.ecfr.gov/current/title-42/part-414)
- [42 CFR Part 415 — Part 415—Services Furnished by Physicians in Providers, Supervising Physicians in Teaching Settings, and Residents in Certain Settings](https://www.ecfr.gov/current/title-42/part-415)

View File

@@ -0,0 +1,37 @@
---
title: main
sidebar_position: 10
---
# main
**Steps:** 14
## Steps
1. **main.alerts_anomaly_detection** — Build main.alerts_anomaly_detection
2. **main.alerts_dbt_tests** — Build main.alerts_dbt_tests
3. **main.alerts_schema_changes** — Build main.alerts_schema_changes
4. **main.anomaly_threshold_sensitivity** — Build main.anomaly_threshold_sensitivity
5. **main.metrics_anomaly_score** — Build main.metrics_anomaly_score
6. **main.monitors_runs** — Build main.monitors_runs
7. **main.alerts_dbt_models** — Build main.alerts_dbt_models
8. **main.alerts_dbt_source_freshness** — Build main.alerts_dbt_source_freshness
9. **main.dbt_artifacts_hashes** — Build main.dbt_artifacts_hashes
10. **main.job_run_results** — Build main.job_run_results
11. **main.hcc_suspecting__list_all** — Build main.hcc_suspecting__list_all
12. **main.model_run_results** — Build main.model_run_results
13. **main.seed_run_results** — Build main.seed_run_results
14. **main.snapshot_run_results** — Build main.snapshot_run_results
## Regulatory References
- [42 CFR Part 405 — Part 405—Federal Health Insurance for the Aged and Disabled](https://www.ecfr.gov/current/title-42/part-405)
- [42 CFR Part 410 — Part 410—Supplementary Medical Insurance (SMI) Benefits](https://www.ecfr.gov/current/title-42/part-410)
- [42 CFR Part 411 — Part 411—Exclusions from Medicare and Limitations on Medicare Payment](https://www.ecfr.gov/current/title-42/part-411)
- [42 CFR Part 414 — Part 414—Payment for Part B Medical and Other Health Services](https://www.ecfr.gov/current/title-42/part-414)
- [42 CFR Part 415 — Part 415—Services Furnished by Physicians in Providers, Supervising Physicians in Teaching Settings, and Residents in Certain Settings](https://www.ecfr.gov/current/title-42/part-415)

View File

@@ -0,0 +1,27 @@
---
title: pharmacy
sidebar_position: 11
---
# pharmacy
**Steps:** 4
## Steps
1. **pharmacy._int_brand_with_generic_available** — Build pharmacy._int_brand_with_generic_available
2. **pharmacy._int_claims_current_cost** — Build pharmacy._int_claims_current_cost
3. **pharmacy._int_generic_cost** — Build pharmacy._int_generic_cost
4. **pharmacy._int_generic_cost_by_ndc** — Build pharmacy._int_generic_cost_by_ndc
## Regulatory References
- [42 CFR Part 405 — Part 405—Federal Health Insurance for the Aged and Disabled](https://www.ecfr.gov/current/title-42/part-405)
- [42 CFR Part 410 — Part 410—Supplementary Medical Insurance (SMI) Benefits](https://www.ecfr.gov/current/title-42/part-410)
- [42 CFR Part 411 — Part 411—Exclusions from Medicare and Limitations on Medicare Payment](https://www.ecfr.gov/current/title-42/part-411)
- [42 CFR Part 414 — Part 414—Payment for Part B Medical and Other Health Services](https://www.ecfr.gov/current/title-42/part-414)
- [42 CFR Part 415 — Part 415—Services Furnished by Physicians in Providers, Supervising Physicians in Teaching Settings, and Residents in Certain Settings](https://www.ecfr.gov/current/title-42/part-415)

View File

@@ -0,0 +1,33 @@
---
title: provider_attribution
sidebar_position: 12
---
# provider_attribution
**Steps:** 10
## Steps
1. **provider_attribution._stg_core__claims_medical_claim** — Build provider_attribution._stg_core__claims_medical_claim
2. **provider_attribution._stg_core__medical_claim** — Build provider_attribution._stg_core__medical_claim
3. **provider_attribution._stg_core__member_months** — Build provider_attribution._stg_core__member_months
4. **provider_attribution._stg_reference_data__calendar** — Build provider_attribution._stg_reference_data__calendar
5. **provider_attribution._stg_terminology__provider** — Build provider_attribution._stg_terminology__provider
6. **provider_attribution._int_person_years** — Build provider_attribution._int_person_years
7. **provider_attribution._int_provider_classification** — Build provider_attribution._int_provider_classification
8. **provider_attribution._int_primary_care_claims** — Build provider_attribution._int_primary_care_claims
9. **provider_attribution._int_current_steps** — Build provider_attribution._int_current_steps
10. **provider_attribution._int_yearly_steps** — Build provider_attribution._int_yearly_steps
## Regulatory References
- [42 CFR Part 405 — Part 405—Federal Health Insurance for the Aged and Disabled](https://www.ecfr.gov/current/title-42/part-405)
- [42 CFR Part 410 — Part 410—Supplementary Medical Insurance (SMI) Benefits](https://www.ecfr.gov/current/title-42/part-410)
- [42 CFR Part 411 — Part 411—Exclusions from Medicare and Limitations on Medicare Payment](https://www.ecfr.gov/current/title-42/part-411)
- [42 CFR Part 414 — Part 414—Payment for Part B Medical and Other Health Services](https://www.ecfr.gov/current/title-42/part-414)
- [42 CFR Part 415 — Part 415—Services Furnished by Physicians in Providers, Supervising Physicians in Teaching Settings, and Residents in Certain Settings](https://www.ecfr.gov/current/title-42/part-415)

View File

@@ -0,0 +1,38 @@
---
title: quality_measures
sidebar_position: 13
---
# quality_measures
**Steps:** 15
## Steps
1. **quality_measures._int_adh_diabetes__performance_period** — Build quality_measures._int_adh_diabetes__performance_period
2. **quality_measures._int_adh_statins__performance_period** — Build quality_measures._int_adh_statins__performance_period
3. **quality_measures._int_adhras__performance_period** — Build quality_measures._int_adhras__performance_period
4. **quality_measures._int_cqm130__performance_period** — Build quality_measures._int_cqm130__performance_period
5. **quality_measures._int_cqm438__performance_period** — Build quality_measures._int_cqm438__performance_period
6. **quality_measures._int_nqf0420__performance_period** — Build quality_measures._int_nqf0420__performance_period
7. **quality_measures._int_supd__performance_period** — Build quality_measures._int_supd__performance_period
8. **quality_measures._stg_condition** — Build quality_measures._stg_condition
9. **quality_measures._stg_encounter** — Build quality_measures._stg_encounter
10. **quality_measures._stg_lab_result** — Build quality_measures._stg_lab_result
11. **quality_measures._stg_medical_claim** — Build quality_measures._stg_medical_claim
12. **quality_measures._stg_medication** — Build quality_measures._stg_medication
13. **quality_measures._stg_observation** — Build quality_measures._stg_observation
14. **quality_measures._stg_patient** — Build quality_measures._stg_patient
15. **quality_measures._stg_pharmacy_claim** — Build quality_measures._stg_pharmacy_claim
## Regulatory References
- [42 CFR Part 405 — Part 405—Federal Health Insurance for the Aged and Disabled](https://www.ecfr.gov/current/title-42/part-405)
- [42 CFR Part 410 — Part 410—Supplementary Medical Insurance (SMI) Benefits](https://www.ecfr.gov/current/title-42/part-410)
- [42 CFR Part 411 — Part 411—Exclusions from Medicare and Limitations on Medicare Payment](https://www.ecfr.gov/current/title-42/part-411)
- [42 CFR Part 414 — Part 414—Payment for Part B Medical and Other Health Services](https://www.ecfr.gov/current/title-42/part-414)
- [42 CFR Part 415 — Part 415—Services Furnished by Physicians in Providers, Supervising Physicians in Teaching Settings, and Residents in Certain Settings](https://www.ecfr.gov/current/title-42/part-415)

View File

@@ -0,0 +1,35 @@
---
title: readmissions
sidebar_position: 14
---
# readmissions
**Steps:** 12
## Steps
1. **readmissions._int_encounter** — Build readmissions._int_encounter
2. **readmissions._int_encounter_overlap** — Build readmissions._int_encounter_overlap
3. **readmissions._int_encounter_with_ccs** — Build readmissions._int_encounter_with_ccs
4. **readmissions._int_procedure_ccs** — Build readmissions._int_procedure_ccs
5. **readmissions._int_encounter_data_quality** — Build readmissions._int_encounter_data_quality
6. **readmissions._int_index_discharge_requirement** — Build readmissions._int_index_discharge_requirement
7. **readmissions._int_index_time_requirement** — Build readmissions._int_index_time_requirement
8. **readmissions._int_exclusion** — Build readmissions._int_exclusion
9. **readmissions._int_index_admission** — Build readmissions._int_index_admission
10. **readmissions._int_planned_encounter** — Build readmissions._int_planned_encounter
11. **readmissions._int_encounter_specialty_cohort** — Build readmissions._int_encounter_specialty_cohort
12. **readmissions._int_readmission_crude** — Build readmissions._int_readmission_crude
## Regulatory References
- [42 CFR Part 405 — Part 405—Federal Health Insurance for the Aged and Disabled](https://www.ecfr.gov/current/title-42/part-405)
- [42 CFR Part 410 — Part 410—Supplementary Medical Insurance (SMI) Benefits](https://www.ecfr.gov/current/title-42/part-410)
- [42 CFR Part 411 — Part 411—Exclusions from Medicare and Limitations on Medicare Payment](https://www.ecfr.gov/current/title-42/part-411)
- [42 CFR Part 414 — Part 414—Payment for Part B Medical and Other Health Services](https://www.ecfr.gov/current/title-42/part-414)
- [42 CFR Part 415 — Part 415—Services Furnished by Physicians in Providers, Supervising Physicians in Teaching Settings, and Residents in Certain Settings](https://www.ecfr.gov/current/title-42/part-415)

View File

@@ -0,0 +1 @@
{"label": "REST API", "position": 11}

View File

@@ -0,0 +1,21 @@
---
title: auth
sidebar_position: 2
---
# auth
### `POST /auth/token`
Issue Token
**Request body** (`application/json`):
Type: `TokenRequest`
**Responses:**
| Status | Description |
|--------|-------------|
| 200 | Successful Response |
| 422 | Validation Error |

35
docs/docs/rest-api/bib.md Normal file
View File

@@ -0,0 +1,35 @@
---
title: bib
sidebar_position: 3
---
# bib
### `GET /bib/items`
List Items
**Parameters:**
| Name | In | Type | Required |
|------|-----|------|----------|
| `tag` | query | string | False |
| `item_type` | query | string | False |
| `limit` | query | integer | False |
**Responses:**
| Status | Description |
|--------|-------------|
| 200 | Successful Response |
| 422 | Validation Error |
### `GET /bib/tags`
List Tags
**Responses:**
| Status | Description |
|--------|-------------|
| 200 | Successful Response |

View File

@@ -0,0 +1,16 @@
---
title: health
sidebar_position: 4
---
# health
### `GET /health`
Health
**Responses:**
| Status | Description |
|--------|-------------|
| 200 | Successful Response |

View File

@@ -0,0 +1,22 @@
---
title: REST API Overview
sidebar_position: 1
---
# REST API
**Title:** stack
**Version:** 0.1.0
## Endpoints
- [auth](./auth) (1 endpoints)
- [bib](./bib) (2 endpoints)
- [health](./health) (1 endpoints)
- [lineage](./lineage) (4 endpoints)
- [pipelines](./pipelines) (4 endpoints)
- [schema](./schema) (1 endpoints)
Full OpenAPI spec: [openapi.json](./openapi.json)

View File

@@ -0,0 +1,53 @@
---
title: lineage
sidebar_position: 5
---
# lineage
### `GET /lineage`
Get Lineage
**Responses:**
| Status | Description |
|--------|-------------|
| 200 | Successful Response |
### `GET /lineage/export/mermaid`
Export Mermaid
**Responses:**
| Status | Description |
|--------|-------------|
| 200 | Successful Response |
### `GET /lineage/export/dot`
Export Dot
**Responses:**
| Status | Description |
|--------|-------------|
| 200 | Successful Response |
### `GET /lineage/{table_ref}`
Get Table Lineage
**Parameters:**
| Name | In | Type | Required |
|------|-----|------|----------|
| `table_ref` | path | string | True |
**Responses:**
| Status | Description |
|--------|-------------|
| 200 | Successful Response |
| 422 | Validation Error |

View File

@@ -0,0 +1,877 @@
{
"openapi": "3.1.0",
"info": {
"title": "stack",
"description": "Healthcare data platform API.",
"version": "0.1.0"
},
"paths": {
"/auth/token": {
"post": {
"tags": [
"auth"
],
"summary": "Issue Token",
"description": "Issue a JWT if the provided secret matches the configured one.",
"operationId": "issue_token_auth_token_post",
"requestBody": {
"content": {
"application/json": {
"schema": {
"$ref": "#/components/schemas/TokenRequest"
}
}
},
"required": true
},
"responses": {
"200": {
"description": "Successful Response",
"content": {
"application/json": {
"schema": {
"$ref": "#/components/schemas/TokenResponse"
}
}
}
},
"422": {
"description": "Validation Error",
"content": {
"application/json": {
"schema": {
"$ref": "#/components/schemas/HTTPValidationError"
}
}
}
}
}
}
},
"/health": {
"get": {
"tags": [
"health"
],
"summary": "Health",
"description": "Return service health and version.",
"operationId": "health_health_get",
"responses": {
"200": {
"description": "Successful Response",
"content": {
"application/json": {
"schema": {
"$ref": "#/components/schemas/HealthResponse"
}
}
}
}
}
}
},
"/pipelines": {
"get": {
"tags": [
"pipelines"
],
"summary": "List Pipelines",
"description": "List all pipelines with step counts.",
"operationId": "list_pipelines_pipelines_get",
"responses": {
"200": {
"description": "Successful Response",
"content": {
"application/json": {
"schema": {
"items": {
"$ref": "#/components/schemas/PipelineSummary"
},
"type": "array",
"title": "Response List Pipelines Pipelines Get"
}
}
}
}
}
}
},
"/pipelines/{name}": {
"get": {
"tags": [
"pipelines"
],
"summary": "Get Pipeline",
"description": "Get pipeline detail: steps, inputs, outputs.",
"operationId": "get_pipeline_pipelines__name__get",
"parameters": [
{
"name": "name",
"in": "path",
"required": true,
"schema": {
"type": "string",
"title": "Name"
}
}
],
"responses": {
"200": {
"description": "Successful Response",
"content": {
"application/json": {
"schema": {
"$ref": "#/components/schemas/PipelineDetail"
}
}
}
},
"422": {
"description": "Validation Error",
"content": {
"application/json": {
"schema": {
"$ref": "#/components/schemas/HTTPValidationError"
}
}
}
}
}
}
},
"/pipelines/run/{pipeline}": {
"post": {
"tags": [
"pipelines"
],
"summary": "Run Pipeline",
"description": "Trigger an async pipeline run.\n\nReturns immediately with a job_id. Poll ``GET /run/{job_id}/status``\nto track progress.",
"operationId": "run_pipeline_pipelines_run__pipeline__post",
"security": [
{
"HTTPBearer": []
}
],
"parameters": [
{
"name": "pipeline",
"in": "path",
"required": true,
"schema": {
"type": "string",
"title": "Pipeline"
}
}
],
"requestBody": {
"content": {
"application/json": {
"schema": {
"anyOf": [
{
"$ref": "#/components/schemas/RunRequest"
},
{
"type": "null"
}
],
"title": "Body"
}
}
}
},
"responses": {
"200": {
"description": "Successful Response",
"content": {
"application/json": {
"schema": {
"$ref": "#/components/schemas/RunResponse"
}
}
}
},
"422": {
"description": "Validation Error",
"content": {
"application/json": {
"schema": {
"$ref": "#/components/schemas/HTTPValidationError"
}
}
}
}
}
}
},
"/pipelines/run/{job_id}/status": {
"get": {
"tags": [
"pipelines"
],
"summary": "Get Run Status",
"description": "Poll job status.",
"operationId": "get_run_status_pipelines_run__job_id__status_get",
"parameters": [
{
"name": "job_id",
"in": "path",
"required": true,
"schema": {
"type": "string",
"title": "Job Id"
}
}
],
"responses": {
"200": {
"description": "Successful Response",
"content": {
"application/json": {
"schema": {
"$ref": "#/components/schemas/RunResponse"
}
}
}
},
"422": {
"description": "Validation Error",
"content": {
"application/json": {
"schema": {
"$ref": "#/components/schemas/HTTPValidationError"
}
}
}
}
}
}
},
"/bib/items": {
"get": {
"tags": [
"bib"
],
"summary": "List Items",
"description": "Query bibliography items.",
"operationId": "list_items_bib_items_get",
"parameters": [
{
"name": "tag",
"in": "query",
"required": false,
"schema": {
"type": "string",
"default": "",
"title": "Tag"
}
},
{
"name": "item_type",
"in": "query",
"required": false,
"schema": {
"type": "string",
"default": "",
"title": "Item Type"
}
},
{
"name": "limit",
"in": "query",
"required": false,
"schema": {
"type": "integer",
"default": 50,
"title": "Limit"
}
}
],
"responses": {
"200": {
"description": "Successful Response",
"content": {
"application/json": {
"schema": {
"type": "array",
"items": {
"$ref": "#/components/schemas/BibItem"
},
"title": "Response List Items Bib Items Get"
}
}
}
},
"422": {
"description": "Validation Error",
"content": {
"application/json": {
"schema": {
"$ref": "#/components/schemas/HTTPValidationError"
}
}
}
}
}
}
},
"/bib/tags": {
"get": {
"tags": [
"bib"
],
"summary": "List Tags",
"description": "List tag namespaces with counts.",
"operationId": "list_tags_bib_tags_get",
"responses": {
"200": {
"description": "Successful Response",
"content": {
"application/json": {
"schema": {
"items": {
"$ref": "#/components/schemas/TagCount"
},
"type": "array",
"title": "Response List Tags Bib Tags Get"
}
}
}
}
}
}
},
"/schema/{table}": {
"get": {
"tags": [
"schema"
],
"summary": "Get Schema",
"description": "Return JSON Schema for a SQLTable model.",
"operationId": "get_schema_schema__table__get",
"parameters": [
{
"name": "table",
"in": "path",
"required": true,
"schema": {
"type": "string",
"title": "Table"
}
}
],
"responses": {
"200": {
"description": "Successful Response",
"content": {
"application/json": {
"schema": {
"type": "object",
"additionalProperties": true,
"title": "Response Get Schema Schema Table Get"
}
}
}
},
"422": {
"description": "Validation Error",
"content": {
"application/json": {
"schema": {
"$ref": "#/components/schemas/HTTPValidationError"
}
}
}
}
}
}
},
"/lineage": {
"get": {
"tags": [
"lineage"
],
"summary": "Get Lineage",
"description": "Return the full table-level lineage graph.",
"operationId": "get_lineage_lineage_get",
"responses": {
"200": {
"description": "Successful Response",
"content": {
"application/json": {
"schema": {
"$ref": "#/components/schemas/LineageResponse"
}
}
}
}
}
}
},
"/lineage/export/mermaid": {
"get": {
"tags": [
"lineage"
],
"summary": "Export Mermaid",
"description": "Export lineage as Mermaid flowchart.",
"operationId": "export_mermaid_lineage_export_mermaid_get",
"responses": {
"200": {
"description": "Successful Response",
"content": {
"application/json": {
"schema": {
"additionalProperties": {
"type": "string"
},
"type": "object",
"title": "Response Export Mermaid Lineage Export Mermaid Get"
}
}
}
}
}
}
},
"/lineage/export/dot": {
"get": {
"tags": [
"lineage"
],
"summary": "Export Dot",
"description": "Export lineage as DOT graph.",
"operationId": "export_dot_lineage_export_dot_get",
"responses": {
"200": {
"description": "Successful Response",
"content": {
"application/json": {
"schema": {
"additionalProperties": {
"type": "string"
},
"type": "object",
"title": "Response Export Dot Lineage Export Dot Get"
}
}
}
}
}
}
},
"/lineage/{table_ref}": {
"get": {
"tags": [
"lineage"
],
"summary": "Get Table Lineage",
"description": "Return lineage for a specific table.",
"operationId": "get_table_lineage_lineage__table_ref__get",
"parameters": [
{
"name": "table_ref",
"in": "path",
"required": true,
"schema": {
"type": "string",
"title": "Table Ref"
}
}
],
"responses": {
"200": {
"description": "Successful Response",
"content": {
"application/json": {
"schema": {
"$ref": "#/components/schemas/TableLineageResponse"
}
}
}
},
"422": {
"description": "Validation Error",
"content": {
"application/json": {
"schema": {
"$ref": "#/components/schemas/HTTPValidationError"
}
}
}
}
}
}
}
},
"components": {
"schemas": {
"BibItem": {
"properties": {
"key": {
"type": "string",
"title": "Key"
},
"title": {
"type": "string",
"title": "Title"
},
"item_type": {
"type": "string",
"title": "Item Type"
}
},
"type": "object",
"required": [
"key",
"title",
"item_type"
],
"title": "BibItem"
},
"HTTPValidationError": {
"properties": {
"detail": {
"items": {
"$ref": "#/components/schemas/ValidationError"
},
"type": "array",
"title": "Detail"
}
},
"type": "object",
"title": "HTTPValidationError"
},
"HealthResponse": {
"properties": {
"status": {
"type": "string",
"title": "Status"
},
"version": {
"type": "string",
"title": "Version"
},
"services": {
"items": {
"$ref": "#/components/schemas/ServiceCheck"
},
"type": "array",
"title": "Services",
"default": []
}
},
"type": "object",
"required": [
"status",
"version"
],
"title": "HealthResponse"
},
"LineageResponse": {
"properties": {
"tables": {
"items": {
"type": "string"
},
"type": "array",
"title": "Tables"
},
"edges": {
"additionalProperties": {
"items": {
"type": "string"
},
"type": "array"
},
"type": "object",
"title": "Edges"
},
"column_sources": {
"additionalProperties": {
"additionalProperties": {
"type": "string"
},
"type": "object"
},
"type": "object",
"title": "Column Sources"
}
},
"type": "object",
"required": [
"tables",
"edges",
"column_sources"
],
"title": "LineageResponse"
},
"PipelineDetail": {
"properties": {
"name": {
"type": "string",
"title": "Name"
},
"steps": {
"type": "integer",
"title": "Steps"
},
"inputs": {
"items": {
"type": "string"
},
"type": "array",
"title": "Inputs"
},
"outputs": {
"items": {
"type": "string"
},
"type": "array",
"title": "Outputs"
}
},
"type": "object",
"required": [
"name",
"steps",
"inputs",
"outputs"
],
"title": "PipelineDetail"
},
"PipelineSummary": {
"properties": {
"name": {
"type": "string",
"title": "Name"
},
"steps": {
"type": "integer",
"title": "Steps"
}
},
"type": "object",
"required": [
"name",
"steps"
],
"title": "PipelineSummary"
},
"RunRequest": {
"properties": {
"target": {
"type": "string",
"title": "Target",
"default": "local"
},
"save": {
"type": "boolean",
"title": "Save",
"default": false
}
},
"type": "object",
"title": "RunRequest"
},
"RunResponse": {
"properties": {
"job_id": {
"type": "string",
"title": "Job Id"
},
"status": {
"type": "string",
"title": "Status"
},
"pipeline": {
"type": "string",
"title": "Pipeline",
"default": ""
},
"started_at": {
"type": "string",
"title": "Started At",
"default": ""
},
"finished_at": {
"type": "string",
"title": "Finished At",
"default": ""
},
"error": {
"type": "string",
"title": "Error",
"default": ""
},
"outputs": {
"additionalProperties": {
"type": "integer"
},
"type": "object",
"title": "Outputs",
"default": {}
}
},
"type": "object",
"required": [
"job_id",
"status"
],
"title": "RunResponse"
},
"ServiceCheck": {
"properties": {
"name": {
"type": "string",
"title": "Name"
},
"status": {
"type": "string",
"title": "Status"
},
"detail": {
"type": "string",
"title": "Detail",
"default": ""
}
},
"type": "object",
"required": [
"name",
"status"
],
"title": "ServiceCheck"
},
"TableLineageResponse": {
"properties": {
"table": {
"type": "string",
"title": "Table"
},
"inputs": {
"items": {
"type": "string"
},
"type": "array",
"title": "Inputs"
},
"column_sources": {
"additionalProperties": {
"type": "string"
},
"type": "object",
"title": "Column Sources"
}
},
"type": "object",
"required": [
"table",
"inputs",
"column_sources"
],
"title": "TableLineageResponse"
},
"TagCount": {
"properties": {
"namespace": {
"type": "string",
"title": "Namespace"
},
"count": {
"type": "integer",
"title": "Count"
}
},
"type": "object",
"required": [
"namespace",
"count"
],
"title": "TagCount"
},
"TokenRequest": {
"properties": {
"secret": {
"type": "string",
"title": "Secret"
}
},
"type": "object",
"required": [
"secret"
],
"title": "TokenRequest"
},
"TokenResponse": {
"properties": {
"access_token": {
"type": "string",
"title": "Access Token"
},
"token_type": {
"type": "string",
"title": "Token Type",
"default": "bearer"
},
"expires_in": {
"type": "integer",
"title": "Expires In",
"default": 3600
}
},
"type": "object",
"required": [
"access_token"
],
"title": "TokenResponse"
},
"ValidationError": {
"properties": {
"loc": {
"items": {
"anyOf": [
{
"type": "string"
},
{
"type": "integer"
}
]
},
"type": "array",
"title": "Location"
},
"msg": {
"type": "string",
"title": "Message"
},
"type": {
"type": "string",
"title": "Error Type"
},
"input": {
"title": "Input"
},
"ctx": {
"type": "object",
"title": "Context"
}
},
"type": "object",
"required": [
"loc",
"msg",
"type"
],
"title": "ValidationError"
}
},
"securitySchemes": {
"HTTPBearer": {
"type": "http",
"scheme": "bearer"
}
}
}
}

View File

@@ -0,0 +1,71 @@
---
title: pipelines
sidebar_position: 6
---
# pipelines
### `GET /pipelines`
List Pipelines
**Responses:**
| Status | Description |
|--------|-------------|
| 200 | Successful Response |
### `GET /pipelines/{name}`
Get Pipeline
**Parameters:**
| Name | In | Type | Required |
|------|-----|------|----------|
| `name` | path | string | True |
**Responses:**
| Status | Description |
|--------|-------------|
| 200 | Successful Response |
| 422 | Validation Error |
### `POST /pipelines/run/{pipeline}`
Run Pipeline
**Parameters:**
| Name | In | Type | Required |
|------|-----|------|----------|
| `pipeline` | path | string | True |
**Request body** (`application/json`):
Type: `RunRequest | null`
**Responses:**
| Status | Description |
|--------|-------------|
| 200 | Successful Response |
| 422 | Validation Error |
### `GET /pipelines/run/{job_id}/status`
Get Run Status
**Parameters:**
| Name | In | Type | Required |
|------|-----|------|----------|
| `job_id` | path | string | True |
**Responses:**
| Status | Description |
|--------|-------------|
| 200 | Successful Response |
| 422 | Validation Error |

View File

@@ -0,0 +1,23 @@
---
title: schema
sidebar_position: 7
---
# schema
### `GET /schema/{table}`
Get Schema
**Parameters:**
| Name | In | Type | Required |
|------|-----|------|----------|
| `table` | path | string | True |
**Responses:**
| Status | Description |
|--------|-------------|
| 200 | Successful Response |
| 422 | Validation Error |

View File

@@ -0,0 +1,118 @@
---
title: Schemas
sidebar_position: 99
---
# Schemas
## `BibItem`
| Field | Type | Required |
|-------|------|----------|
| `key` | string | yes |
| `title` | string | yes |
| `item_type` | string | yes |
## `HTTPValidationError`
| Field | Type | Required |
|-------|------|----------|
| `detail` | list[ValidationError] | |
## `HealthResponse`
| Field | Type | Required |
|-------|------|----------|
| `status` | string | yes |
| `version` | string | yes |
| `services` | list[ServiceCheck] | |
## `LineageResponse`
| Field | Type | Required |
|-------|------|----------|
| `tables` | list[string] | yes |
| `edges` | object | yes |
| `column_sources` | object | yes |
## `PipelineDetail`
| Field | Type | Required |
|-------|------|----------|
| `name` | string | yes |
| `steps` | integer | yes |
| `inputs` | list[string] | yes |
| `outputs` | list[string] | yes |
## `PipelineSummary`
| Field | Type | Required |
|-------|------|----------|
| `name` | string | yes |
| `steps` | integer | yes |
## `RunRequest`
| Field | Type | Required |
|-------|------|----------|
| `target` | string | |
| `save` | boolean | |
## `RunResponse`
| Field | Type | Required |
|-------|------|----------|
| `job_id` | string | yes |
| `status` | string | yes |
| `pipeline` | string | |
| `started_at` | string | |
| `finished_at` | string | |
| `error` | string | |
| `outputs` | object | |
## `ServiceCheck`
| Field | Type | Required |
|-------|------|----------|
| `name` | string | yes |
| `status` | string | yes |
| `detail` | string | |
## `TableLineageResponse`
| Field | Type | Required |
|-------|------|----------|
| `table` | string | yes |
| `inputs` | list[string] | yes |
| `column_sources` | object | yes |
## `TagCount`
| Field | Type | Required |
|-------|------|----------|
| `namespace` | string | yes |
| `count` | integer | yes |
## `TokenRequest`
| Field | Type | Required |
|-------|------|----------|
| `secret` | string | yes |
## `TokenResponse`
| Field | Type | Required |
|-------|------|----------|
| `access_token` | string | yes |
| `token_type` | string | |
| `expires_in` | integer | |
## `ValidationError`
| Field | Type | Required |
|-------|------|----------|
| `loc` | list[string | integer] | yes |
| `msg` | string | yes |
| `type` | string | yes |
| `input` | object | |
| `ctx` | object | |

18447
docs/package-lock.json generated Normal file

File diff suppressed because it is too large Load Diff