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

sub-job

ECP · Load-Account-Transform-Tables-RevFind

NextGen Transforms-RevFind

called by Daily-Accounts-Processing-RevFind

sub-job ECP/Load-Account-Transform-Tables-RevFind · db ECP_ProdMirror · updated 2026-05-20

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-RevFind

17 tasks · ECP
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. Fill AccountKeyMapsqlload_account_transform_tables_revfind__fill_accountkeymap.sql
    ✨ Maintains a mapping of source system identifiers and encounter details to unique internal account keys based on recent modifications.
  2. Create AccountDeltasqlload_account_transform_tables_revfind__create_accountdelta.sql
    ✨ Populates the delta table with accounts that have recent activity, modified charges, or updated location mappings since the last run.
    writes AccountDelta · reads AccountDeltaAccountKeyMapProcessLogSourceChargeSourceEncounterSourceLocationMapSourceTransactionTransformAccount
    ↳ feeds from Load TransformAccount, Load TransformCharge, Load TransformTransaction
  3. Load TransformPatientsqlload_account_transform_tables_revfind__load_transformpatient.sql
    ✨ Updates the transformed patient table with demographic information, contact details, and standardized identifiers from the source system.
    writes TransformPatient · reads SourcePatient
  4. Load TransformLocationsqlload_account_transform_tables_revfind__load_transformlocation.sql
    ✨ Builds the location transformation table by mapping source locations to standardized addresses and place of service codes.
    writes TransformLocation · reads SourceLocationSourceLocationMap
  5. Load TransformProvidersqlload_account_transform_tables_revfind__load_transformprovider.sql
    ✨ Updates the provider transformation table with standardized names, credentials, and NPI identifiers from source systems.
    writes TransformProvider · reads SourceProvider
  6. Load TransformPayersqlload_account_transform_tables_revfind__load_transformpayer.sql
    ✨ Loads the payer transformation table with standardized insurance carrier names, plan types, and financial classifications.
    writes TransformPayer · reads SourcePayers
  7. Load TransformChargesqlload_account_transform_tables_revfind__load_transformcharge.sql
    ✨ Builds the charge transformation table by calculating bill types, procedure codes, and balances for specific account encounters.
    writes TransformCharge · reads AccountDeltaAccountKeyMapSourceBillingEntitySourceChargeSourceEncounterSourceLocationMapTransformLocation
    ↳ feeds from Create AccountDelta, Load TransformLocation
  8. Load TransformTransactionsqlload_account_transform_tables_revfind__load_transformtransaction.sql
    ✨ Loads the transaction transformation table by categorizing financial adjustments, denials, and payments for specific patient accounts.
    writes TransformTransaction · reads AccountDeltaAdjustmentCodeRollupSourceTransactionTransformCharge
    ↳ feeds from Create AccountDelta, Load TransformCharge
  9. Load TransformAccountsqlload_account_transform_tables_revfind__load_transformaccount.sql
    ✨ Builds the account transformation table by aggregating encounter details, provider information, and financial balances for active accounts.
    writes TransformAccount · reads AccountDeltaAccountKeyMapSourceBillingEntitySourceEncounterSourceEncounterInsuranceSourceLocationMapTransformCharge
    ↳ feeds from Create AccountDelta, Load TransformCharge
  10. Load TransformAccountInsurancesqlload_account_transform_tables_revfind__load_transformaccountinsurance.sql
    ✨ Loads the account insurance transformation table by mapping primary, secondary, and tertiary coverage details for each account.
    writes TransformAccountInsurance · reads AccountDeltaSourceEncounterInsuranceTransformCharge
    ↳ feeds from Create AccountDelta, Load TransformCharge
  11. Load TransformRemitAdjustmentsqlload_account_transform_tables_revfind__load_transformremitadjustment.sqldisabled
    ✨ Builds the remittance adjustment transformation table by categorizing insurance denials and mapping reason codes to standardized adjustment types.
    writes TransformRemitAdjustment · reads AccountDelta
  12. Load TransformRemitsqlload_account_transform_tables_revfind__load_transformremit.sqldisabled
    ✨ Builds the remit transformation table by consolidating electronic remittance advice adjustments and transaction-level payment data for updated encounters.
    writes TransformRemit · reads EncounterDeltaTransformRemitTransformRemitAdjustmentTransformTransactionPaymentAdjustment
  13. Load TransformRemitAdjustmentAggregatesqlload_account_transform_tables_revfind__load_transformremitadjustmentaggregate.sqldisabled
    ✨ Aggregates remittance adjustments to calculate total contract, patient, and denial amounts at the charge level for updated accounts.
    writes TransformRemitAdjustmentAggregate · reads AccountDeltaTransformChargeTransformRemitAdjustment
  14. Load TransformChargeTransactionMeasuressqlload_account_transform_tables_revfind__load_transformchargetransactionmeasures.sql
    ✨ Calculates and loads transaction-based financial measures, including payments, adjustments, and denial categories, for each charge in updated accounts.
    writes TransformChargeTransactionMeasure · reads AccountDeltaTransformChargeTransformTransaction
    ↳ feeds from Create AccountDelta, Load TransformCharge, Load TransformTransaction
  15. Load TempChargeLinkRemitsqlload_account_transform_tables_revfind__load_tempchargelinkremit.sql
    ✨ Creates a temporary mapping table to link charges with remittance data using procedure codes, modifiers, and service dates.
    writes TempChargeLinkRemit · reads ChargeTypeSourceChargeTempChargeLinkRemitTransformAccountTransformCharge
    ↳ feeds from Load TransformAccount, Load TransformCharge
  16. Load TempTransactionsAggTotalLinksqlload_account_transform_tables_revfind__load_temptransactionsaggtotallink.sql
    ✨ Aggregates transaction totals and links them to specific charges or accounts using previously defined matching keys and procedure codes.
  17. Merge 835 Updates to TransformChargeTransactionMeasuresqlload_account_transform_tables_revfind__merge_835_updates_to_transformchargetransactionmeasure.sql
    ✨ Merges aggregated electronic remittance data into the charge transaction measure table to update payment, adjustment, and denial metrics.
    writes TransformChargeTransactionMeasure · reads TempTransactionsAggTotalLinkTransformCharge
    ↳ feeds from Load TransformCharge