Legacy Pipeline Atlas worker-1snapshot 2026-07-15

sub-job

CCP · Load-Account-Transform-Tables

Source-->Transform

called by Daily-Accounts-Processing

sub-job CCP/Load-Account-Transform-Tables · db CCP_ProdMirror · updated 2025-10-21

task tree

What the sub-job runs

Tasks in order, each with what it does — typed stepsfrom the MDClarity task docs (click to open the reference), sub-jobsyou can expand inline (▶) to reveal their own tasks, and SQL steps summarized by Gemini (✨). Every step shows the tables it writes/reads and which earlier step it feeds from(sqlglot lineage).

sub-job

Load-Account-Transform-Tables

9 tasks · CCP
sub-job / Flow action SQL / native step▶ expand a sub-job inline · ↗ open it as its own page · a typed step opens its doc
  1. Load AccountDeltasqlload_account_transform_tables__load_accountdelta.sql
    ✨ Builds a list of account identifiers from the import log to track records requiring transformation in the current pipeline run.
    writes AccountDelta · reads AccountDelta
  2. Load TransformPatientsqlload_account_transform_tables__load_transformpatient.sql
    ✨ Updates or inserts patient demographic information, including names, contact details, and addresses, from source data into the transformed patient table.
    writes TransformPatient · reads SourcePatient
  3. Load TransformInvoiceChainsqlload_account_transform_tables__load_transforminvoicechain.sql
    ✨ Builds a historical chain of invoice relationships for specific accounts, identifying current, cloned, and rebilled charge headers.
    writes TransformInvoiceChain · reads AccountDeltaSourceChargeHeader
    ↳ feeds from Load AccountDelta
  4. Load TransformAccountsqlload_account_transform_tables__load_transformaccount.sql
    ✨ Consolidates account-level details, including facility, patient, and primary insurance information, for records identified in the current processing delta.
    writes TransformAccount · reads AccountDeltaSourceInsuranceSourceLocationSourceLogBookSourceLogDetailSourcePatBillingTransformInvoiceChain
    ↳ feeds from Load AccountDelta, Load TransformInvoiceChain
  5. Load TransformChargesqlload_account_transform_tables__load_transformcharge.sql
    ✨ Loads detailed service charge information, including procedure codes, modifiers, and payment balances, for accounts requiring updates.
    writes TransformCharge · reads AccountDeltaSourceChargeDetailSourceChargeHeaderSourceInsuranceSourcePatBillingTransformInvoiceChain
    ↳ feeds from Load AccountDelta, Load TransformInvoiceChain
  6. Load TransformTransactionsqlload_account_transform_tables__load_transformtransaction.sql
    ✨ Records financial transactions, such as payments and adjustments, while establishing chronological posting orders for each account's billing history.
    writes TransformTransaction · reads AccountDeltaSourceARDetailSourceARHeaderSourceInsuranceSourcePatBilling
    ↳ feeds from Load AccountDelta
  7. Load TransformRemitAdjustmentsqlload_account_transform_tables__load_transformremitadjustment.sql
    ✨ Loads insurance remittance adjustments and denial codes from electronic advice, linking them to specific charges and invoice chains.
    writes TransformRemitAdjustment · reads AccountDeltaAdjustmentCodeRollupSourceARHeaderSourceERAAdjustmentSourceInsuranceSourcePatBillingTransformAccountTransformInvoiceChain
    ↳ feeds from Load AccountDelta, Load TransformAccount, Load TransformInvoiceChain
  8. Load TransformRemitAdjustmentAggsqlload_account_transform_tables__load_transformremitadjustmentagg.sql
    ✨ Aggregates insurance denial data by category and amount to summarize initial and final remittance adjustments for each account.
    writes TransformRemitAdjustmentAgg · reads AccountDeltaTransformRemitAdjustment
    ↳ feeds from Load AccountDelta, Load TransformRemitAdjustment
  9. Load TransformChargeTransactionMeasuresqlload_account_transform_tables__load_transformchargetransactionmeasure.sql
    ✨ Builds financial measures for charges, including payments, adjustments, and denials, while mapping coordination of benefits and denial categories.
    writes TransformChargeTransactionMeasure · reads AccountDeltaTransformAccountTransformChargeTransformInvoiceChainTransformRemitAdjustmentAggTransformTransaction
    ↳ feeds from Load AccountDelta, Load TransformAccount, Load TransformCharge, Load TransformInvoiceChain, Load TransformRemitAdjustmentAgg, Load TransformTransaction