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

Batch / file feed · RevFind pipeline

Commonwealth · Daily-Accounts-Processing

Process Athena Accounts

pipeline Commonwealth/Daily-Accounts-Processing · db Commonwealth_ProdMirror · updated 2026-01-16
classification: revfind · loads 2 visit tables

Loads visit tables
Besides its back-office work, this RevFind pipeline also loads a visit dimension/fact table (Load VisitStatus Dimension, Load VisitType Dimensions) — the shared rows Flow builds on. It runs no front-of-house work (no eligibility, estimate, or letters), so it stays RevFind.

trigger

How it's scheduled

Daily batch — once at 00:30

The Batch / file feed arrives as a scheduled drop, so one overnight pass is enough: it ingests the day's file and works the whole batch to process the visits. A tighter loop would just re-scan the same file.

Scheduled taskCadenceServerStateCoordination
\MDC\Daily - Processing - Commonwealthdaily at 00:30prod-db-3disabledstandalone

shape

The RevFind back-office spine

RevFind pipelines share a back-office shape: ingest → load accounts → reconcile remits → model contracts → surface underpayments. Lit stages are the ones this pipeline runs.

Ingest
Batch / file feed
→
Accounts / AR
ACCT
→
Remit (835)
835
→
Contract model
CTR
→
Payer rules
→
Work queue & sync
Sync

computed concepts · from the SQL

What it computes

Business concepts mined from this pipeline's SQL text — the meaning behind the typed steps. Each links to the concept lens (who else computes it).

Letter suppressionFee schedule / contractExpected reimbursementDenial / underpaymentCPT / procedure logic

Payers in SQLMedicare

task tree

What the pipeline 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).

revfind

Daily-Accounts-Processing

10 tasks · Commonwealth
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-Athena-Data-ImportSqlsub-job · 44↗
    1. ImportClinicalEncounterImportClinicalEncounter
      Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
      writes ImportClinicalEncounter
      connection string={AthenaConnectionString}table name=ImportClinicalEncounterimport mode=Replacedata source type=Snowflake
    2. Merge SourceClinicalEncountersqlload_athena_data_importsql__merge_sourceclinicalencounter.sql
      ✨ Synchronizes clinical encounter details from imported data to the source layer to reflect the most recent patient visits.
      writes SOURCECLINICALENCOUNTER · reads ImportClinicalEncounter
      ↳ feeds from ImportClinicalEncounter
    3. ImportAppointmentImportAppointment
      Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
      writes ImportAppointment
      connection string={AthenaConnectionString}table name=ImportAppointmentimport mode=Replacedata source type=Snowflake
    4. Merge SourceAppointmentsqlload_athena_data_importsql__merge_sourceappointment.sql
      ✨ Updates the source appointment table with the latest scheduling, check-in, and status information from the import layer.
      writes SourceAppointment · reads ImportAppointment
      ↳ feeds from ImportAppointment
    5. ImportClaimImportClaim
      Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
      writes ImportClaim
      connection string={AthenaConnectionString}table name=ImportClaimimport mode=Replacedata source type=Snowflake
    6. Merge SourceClaimsqlload_athena_data_importsql__merge_sourceclaim.sql
      ✨ Merges the latest insurance claim data into the source layer to track billing status and outstanding balances.
      writes SOURCECLAIM · reads ImportClaim
      ↳ feeds from ImportClaim
    7. ImportTransactionImportTransaction
      Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
      writes ImportTransaction
      connection string={AthenaConnectionString}table name=ImportTransactionimport mode=Replacedata source type=Snowflake
    8. Merge SourceTransactionsqlload_athena_data_importsql__merge_sourcetransaction.sql
      ✨ Updates the master transaction table with new or modified records from the imported transaction data.
      writes SOURCETRANSACTION · reads ImportTransaction
      ↳ feeds from ImportTransaction
    9. Merge SourceTransactionChargesqlload_athena_data_importsql__merge_sourcetransactioncharge.sql
      ✨ Updates the charge transaction table by filtering and synchronizing charge-type records from the main transaction source.
      writes SOURCETRANSACTIONCHARGE · reads SOURCETRANSACTION
      ↳ feeds from Merge SourceTransaction
    10. Merge SourceTransactionPaymentsqlload_athena_data_importsql__merge_sourcetransactionpayment.sql
      ✨ Updates the payment transaction table by filtering and synchronizing payment-type records from the main transaction source.
      writes SOURCETRANSACTIONPAYMENT · reads SOURCETRANSACTION
      ↳ feeds from Merge SourceTransaction
    11. Merge SourceTransactionAdjustmentsqlload_athena_data_importsql__merge_sourcetransactionadjustment.sql
      ✨ Updates the adjustment transaction table by filtering and synchronizing adjustment-type records from the main transaction source.
      writes SOURCETRANSACTIONADJUSTMENT · reads SOURCETRANSACTION
      ↳ feeds from Merge SourceTransaction
    12. Merge SourceTransactionTransfersqlload_athena_data_importsql__merge_sourcetransactiontransfer.sql
      ✨ Updates the transfer transaction table by filtering and synchronizing transfer-in and transfer-out records from the main transaction source.
      writes SOURCETRANSACTIONTRANSFER · reads SOURCETRANSACTION
      ↳ feeds from Merge SourceTransaction
    13. ImportERABatchImportERABatch
      Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
      writes ImportERABatch
      connection string={AthenaConnectionString}table name=ImportERABatchimport mode=Replacedata source type=Snowflake
    14. Merge SourceERABatchsqlload_athena_data_importsql__merge_sourceerabatch.sql
      ✨ Synchronizes electronic remittance advice batch information from the import staging area to the source batch table.
      writes SOURCEERABATCH · reads ImportERABatch
      ↳ feeds from ImportERABatch
    15. ImportERARecordImportERARecord
      Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
      writes ImportERARecord
      connection string={AthenaConnectionString}table name=ImportERARecordimport mode=Replacedata source type=Snowflake
    16. Merge SourceERARecordsqlload_athena_data_importsql__merge_sourceerarecord.sql
      ✨ Synchronizes individual electronic remittance advice records from the import staging area to the source record table.
      writes SOURCEERARECORD · reads ImportERARecord
      ↳ feeds from ImportERARecord
    17. ImportERADetailImportERADetail
      Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
      writes ImportERADetail
      connection string={AthenaConnectionString}table name=ImportERADetailimport mode=Replacedata source type=Snowflake
    18. Merge SourceERADetailsqlload_athena_data_importsql__merge_sourceeradetail.sql
      ✨ Synchronizes granular electronic remittance advice details from the import staging area to the source detail table.
      writes SOURCEERADETAIL · reads ImportERADetail
      ↳ feeds from ImportERADetail
    19. ImportERAKickImportERAKick
      Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
      writes ImportERAKick
      connection string={AthenaConnectionString}table name=ImportERAKickimport mode=Replacedata source type=Snowflake
    20. Merge SourceERAKicksqlload_athena_data_importsql__merge_sourceerakick.sql
      ✨ Updates or inserts electronic remittance advice kick records to track claim rejections and mapping details within the pipeline.
      writes SOURCEERAKICK · reads ImportERAKick
      ↳ feeds from ImportERAKick
    21. ImportClaimNoteImportClaimNote
      Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
      writes ImportClaimNote
      connection string={AthenaConnectionString}table name=ImportClaimNoteimport mode=Replacedata source type=Snowflake
    22. Merge SourceClaimNotesqlload_athena_data_importsql__merge_sourceclaimnote.sql
      ✨ Updates or inserts claim notes and status information to maintain a history of billing actions and denial reasons.
      writes SOURCECLAIMNOTE · reads ImportClaimNote
      ↳ feeds from ImportClaimNote
    23. ImportDenialClaimNoteImportDenialClaimNote
      Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
      writes ImportDenialClaimNote
      connection string={AthenaConnectionString}table name=ImportDenialClaimNoteimport mode=Replacedata source type=Snowflake
    24. Merge SourceDenialClaimNotesqlload_athena_data_importsql__merge_sourcedenialclaimnote.sql
      ✨ Updates or inserts denial-specific claim notes to track rejection reasons, provider details, and claim status changes.
      writes SOURCEDENIALCLAIMNOTE · reads ImportDenialClaimNote
      ↳ feeds from ImportDenialClaimNote
    25. ImportPatientImportPatient
      Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
      writes ImportPatient
      connection string={AthenaConnectionString}table name=ImportPatientimport mode=Replacedata source type=Snowflake
    26. Merge SourcePatientsqlload_athena_data_importsql__merge_sourcepatient.sql
      ✨ Updates or inserts patient demographic and contact information to ensure accurate patient identification and communication records.
      writes SOURCEPATIENT · reads ImportPatient
      ↳ feeds from ImportPatient
    27. ImportPayerImportPayer
      Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
      writes ImportPayer
      connection string={AthenaConnectionString}table name=ImportPayerimport mode=Replacedata source type=Snowflake
    28. Merge SourcePayersqlload_athena_data_importsql__merge_sourcepayer.sql
      ✨ Updates or inserts insurance payer and package details to manage coverage types, reporting categories, and effective dates.
      writes SOURCEPAYER · reads ImportPayer
      ↳ feeds from ImportPayer
    29. ImportPatientInsuranceImportPatientInsurance
      Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
      writes ImportPatientInsurance
      connection string={AthenaConnectionString}table name=ImportPatientInsuranceimport mode=Replacedata source type=Snowflake
    30. Merge SourcePatientInsurancesqlload_athena_data_importsql__merge_sourcepatientinsurance.sql
      ✨ Updates or inserts patient insurance policy records, including coverage sequence, policy numbers, and eligibility status.
      writes SOURCEPATIENTINSURANCE · reads ImportPatientInsurance
      ↳ feeds from ImportPatientInsurance
    31. ImportProviderImportProvider
      Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
      writes ImportProvider
      connection string={AthenaConnectionString}table name=ImportProviderimport mode=Replacedata source type=Snowflake
    32. Merge SourceProvidersqlload_athena_data_importsql__merge_sourceprovider.sql
      ✨ Updates or inserts healthcare provider information, including NPI numbers, specialties, and taxonomy codes for billing and reporting.
      writes SOURCEPROVIDER · reads ImportProvider
      ↳ feeds from ImportProvider
    33. ImportDepartmentImportDepartment
      Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
      writes ImportDepartment
      connection string={AthenaConnectionString}table name=ImportDepartmentimport mode=Replacedata source type=Snowflake
    34. Merge SourceDepartmentsqlload_athena_data_importsql__merge_sourcedepartment.sql
      ✨ Updates or inserts clinical department and facility location data to support accurate service location tracking and billing.
      writes SOURCEDEPARTMENT · reads ImportDepartment
      ↳ feeds from ImportDepartment
    35. ImportFeeScheduleProcedureImportFeeScheduleProcedure
      Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
      writes ImportFeeScheduleProcedure
      connection string={AthenaConnectionString}table name=ImportFeeScheduleProcedureimport mode=Replacedata source type=Snowflake
    36. Merge SourceFeeScheduleProceduresqlload_athena_data_importsql__merge_sourcefeescheduleprocedure.sql
      ✨ Updates the source fee schedule procedure table with the latest pricing and procedure code mappings from imported data.
      writes SOURCEFEESCHEDULEPROCEDURE · reads ImportFeeScheduleProcedure
      ↳ feeds from ImportFeeScheduleProcedure
    37. ImportProcedureCodeImportProcedureCode
      Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
      writes ImportProcedureCode
      connection string={AthenaConnectionString}table name=ImportProcedureCodeimport mode=Replacedata source type=Snowflake
    38. Merge SourceProcedureCodesqlload_athena_data_importsql__merge_sourceprocedurecode.sql
      ✨ Updates the master procedure code list with current descriptions, groups, and effective dates from the source system.
      writes SOURCEPROCEDURECODE · reads ImportProcedureCode
      ↳ feeds from ImportProcedureCode
    39. ImportFeeScheduleImportFeeSchedule
      Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
      writes ImportFeeSchedule
      connection string={AthenaConnectionString}table name=ImportFeeScheduleimport mode=Replacedata source type=Snowflake
    40. Merge SourceFeeSchedulesqlload_athena_data_importsql__merge_sourcefeeschedule.sql
      ✨ Updates the source fee schedule headers with current names, insurance package links, and effective dates from imported data.
      writes SOURCEFEESCHEDULE · reads ImportFeeSchedule
      ↳ feeds from ImportFeeSchedule
    41. ImportProcedureCodeModifierImportProcedureCodeModifier
      Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
      writes ImportProcedureCodeModifier
      connection string={AthenaConnectionString}table name=ImportProcedureCodeModifierimport mode=Replacedata source type=Snowflake
    42. Merge SourceProcedureCodeModifiersqlload_athena_data_importsql__merge_sourceprocedurecodemodifier.sql
      ✨ Updates the source procedure code modifier table with the latest descriptions and metadata from the imported source data.
      writes SOURCEPROCEDURECODEMODIFIER · reads ImportProcedureCodeModifier
      ↳ feeds from ImportProcedureCodeModifier
    43. Merge SourceChargeMastersqlload_athena_data_importsql__merge_sourcechargemaster.sql
      ✨ Builds the charge master by joining fee schedules and procedure codes to maintain standard pricing and modifier details.
      writes SOURCECHARGEMASTER · reads sourcefeeschedulesourcefeescheduleproceduresourceprocedurecode
      ↳ feeds from Merge SourceFeeSchedule, Merge SourceFeeScheduleProcedure, Merge SourceProcedureCode
    44. Merge SourceTimesheetEntryTransactionMergeSql
      writes SourceTimesheetEntryTransaction · reads TIMESHEETENTRYTIMESHEETENTRYTRANSACTION
      merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceTimesheetEntryTransactionmerge mode=InsertUpdatebulk copy timeout seconds=300
  2. ▶Load-InsuranceMapsub-job · 3↗
    1. Load-InsuranceMapLoad-InsuranceMapdisabled
      writes InsuranceMap · reads InsuranceMapSourcePayer
      entity type=InsuranceMapauto querykey prefix=IMDISABLED
    2. Load-InsuranceMap-With-Import-TableLoad-InsuranceMap-With-Import-Tabledisabled
      writes InsuranceMap · reads InsuranceMapSourceInsuranceMapImportSourcePayer
      entity type=InsuranceMapcustom querykey prefix=IMDISABLED
    3. Load-InsuranceMap (InsPackageID)LoadEntities
      writes InsuranceMap · reads InsuranceMapSourcePayer
      entity type=InsuranceMapcustom querykey prefix=IM
  3. ▶Load-ChargeTypesub-job · 6↗Load the Charge Types from ChargeMaster + CPT Crosswalk
    1. Load-ImportChargeTypesqlload_chargetype__load_importchargetype.sql
      ✨ Loads formatted charge type definitions from the charge master to prepare display names and billing codes for the system.
      writes ImportChargeType · reads SourceChargeMaster
    2. Merge-ChargeTypesqlload_chargetype__merge_chargetype.sql
      ✨ Updates the final charge type table with claim-level and procedure-specific billing configurations for use across the application.
      writes ChargeType · reads ImportChargeType
      ↳ feeds from Load-ImportChargeType
    3. Update-ProcedureCode-DimensionMembersqlload_chargetype__update_procedurecode_dimensionmember.sql
      ✨ Updates the procedure code dimension with member IDs, descriptions, and category hierarchies to support clinical service reporting.
      writes DimensionMember · reads ChargeTypeProcedureCode
      ↳ feeds from Merge-ChargeType
    4. Update-ChargeType-DimensionMembersqlload_chargetype__update_chargetype_dimensionmember.sql
      ✨ Loads charge type identifiers and display names into the dimension table to categorize financial transactions.
      writes DimensionMember · reads ChargeType
      ↳ feeds from Merge-ChargeType
    5. Update ChargeMaster SchedulesUpdateFeePricing
      writes FeePricingRecord · reads SourceChargeMaster
      schedule insert type=Replaceschedule type=Chargessource table=SourceChargeMaster
    6. Load Charges SchedulesLoadFeeSchedules
      Generate time-based fee schedules from pricing records to establish effective date ranges for facility and insurance billing combinations.
      writes ScheduleScheduleMap · reads FeePricingRecord
      ↳ feeds from Update ChargeMaster Schedules
  4. ▶Load-Account-Transform-Tablessub-job · 12↗Athena Transforms
    1. Check AccountDeltasqlload_account_transform_tables__check_accountdelta.sql
      ✨ Ensures the account delta table exists with the correct schema, including necessary columns and indexes for tracking changed records.
      · reads AccountDelta
      ↳ feeds from Create AccountDelta
    2. Create AccountDeltasqlload_account_transform_tables__create_accountdelta.sql
      ✨ Identifies and loads accounts, encounters, and claims updated since the last pipeline execution into the delta table.
      writes AccountDelta · reads ProcessLogSourceAppointmentSourceClaimSourceClinicalEncounterSourceERADetailSourcePatientInsuranceSourceTransaction
    3. Load TransformTransaction - Updated for Claims sans Visitssqlload_account_transform_tables__load_transformtransaction_updated_for_claims_sans_visits.sql
      ✨ Standardizes and loads financial transaction data, including payments and adjustments, for updated accounts into the transaction transformation table.
      writes TransformTransaction · reads AccountDeltaSourceClaimSourcePatientInsuranceSourceTransactionsourceclaimnote
      ↳ feeds from Create AccountDelta
    4. Load TransformRemitAdjustment - Updated for Claims sans Visitssqlload_account_transform_tables__load_transformremitadjustment_updated_for_claims_sans_visits.sql
      ✨ Processes and loads remittance adjustment details, including denial categories and group codes, from electronic remittance advice into the transformation table.
      writes TransformRemitAdjustment · reads AccountDeltaAdjustmentCodeRollupSourceClaimSourceERABatchSourceERADetailSourceERAKickSourceERARecordSourcePatientInsurance
      ↳ feeds from Create AccountDelta
    5. Load TransformCharge - Updated for Claims sans Visitssqlload_account_transform_tables__load_transformcharge_updated_for_claims_sans_visits.sql
      ✨ Transforms and loads charge-level details, including procedure codes, modifiers, and diagnosis information, for updated accounts into the charge table.
      writes TransformCharge · reads AccountDeltaSourceClaimSourceDepartmentSourceTimesheetEntryTransactionSourceTransactionSourceTransactionCharge
      ↳ feeds from Create AccountDelta
    6. Load TransformAccount - Updated for Claims sans Visitssqlload_account_transform_tables__load_transformaccount_updated_for_claims_sans_visits.sql
      ✨ Builds unified account records by merging clinical encounter and billing claim data for comprehensive financial tracking.
      writes TransformAccount · reads AccountDeltaSourceClaimSourceClinicalEncounterSourceDepartmentSourcePatientInsuranceSourceProvider
      ↳ feeds from Create AccountDelta
    7. Load TransformRemitAdjustmentAggregatesqlload_account_transform_tables__load_transformremitadjustmentaggregate.sql
      ✨ Aggregates insurance remittance adjustments and denial categories to summarize payment impacts at the encounter level.
      writes TransformRemitAdjustmentAggregate · reads AccountDeltaTransformChargeTransformRemitAdjustment
      ↳ feeds from Create AccountDelta, Load TransformCharge - Updated for Claims sans Visits, Load TransformRemitAdjustment - Updated for Claims sans Visits
    8. Load TransformChargeTransactionMeasuressqlload_account_transform_tables__load_transformchargetransactionmeasures.sql
      ✨ Calculates total financial measures per charge, including payments, adjustments, and denials, for detailed revenue analysis.
      writes TransformChargeTransactionMeasure · reads AccountDeltaTransformChargeTransformRemitAdjustmentAggregateTransformTransaction
      ↳ feeds from Create AccountDelta, Load TransformCharge - Updated for Claims sans Visits, Load TransformRemitAdjustmentAggregate, Load TransformTransaction - Updated for Claims sans Visits
    9. Load TransformPatientsqlload_account_transform_tables__load_transformpatient.sqldisabled
      ✨ Updates and maintains patient demographic information in the transformation layer to ensure accurate patient identification.
      writes TransformPatient · reads SourcePatient
    10. ExecuteMergeSql (TransformPatient)MergeSql
      writes TransformPatient · reads SourcePatient
      merge data source type=ThisDatabasetable name=TransformPatientmerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
    11. Load TransformPatientInsurancesqlload_account_transform_tables__load_transformpatientinsurance.sqldisabled
      ✨ Manages patient insurance coverage records, updating active policies and removing expired or cancelled insurance information.
      writes TransformPatientInsurance · reads InsuranceMapSourcePatientInsuranceSourcePayer
    12. ExecuteMergeSql (TransformPatientInsurance)MergeSql
      writes TransformPatientInsurance · reads InsuranceMapSourcePatientInsuranceSourcePayer
      merge data source type=ThisDatabasetable name=TransformPatientInsurancemerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
  5. ▶Load-Patients-Entitysub-job · 1↗
    1. Execute LoadPatientsLoadPatients
      Upsert patient records into the patient dimension.
      · reads PatientTransformPatient
      custom patient query
  6. ▶Load-Entitiessub-job · 2↗Load Facility, Provider
    1. Load FacilityLoadEntities
      writes Facility · reads FacilitySourceDepartment
      entity type=Facilitycustom query
    2. Load Providersqlload_entities__load_provider.sql
      ✨ Updates the provider registry with names, NPI numbers, and taxonomy codes from source system data.
      writes Provider · reads SourceProvider
  7. ▶Load-Batch-Dimension-Memberssub-job · 1↗
    1. Load Modifier Dimensionsqlload_batch_dimension_members__load_modifier_dimension.sql
      ✨ Loads procedure code modifier dimension members to support detailed billing analysis and accurate claim processing.
      writes DIMENSIONMEMBER · reads SOURCEPROCEDURECODEMODIFIER
  8. ▶Load-Account-Datasub-job · 7↗Load Account-Level Tables
    1. Augment AccountDeltaReprocessChangedConfigs
      reprocess accounts
    2. Augment AccountDelta ReprocessChangedConfigurationssqlload_account_data__augment_accountdelta_reprocesschangedconfigurations.sql
      ✨ Adds accounts requiring reprocessing due to configuration changes into the account delta table for downstream processing.
      writes AccountDelta · reads AccountDeltaAccountsToReprocessTransformAccount
    3. Load ChargeMeasuressqlload_account_data__load_chargemeasures.sql
      ✨ Calculates and loads financial metrics like payments, adjustments, and denials for specific accounts into the charge measures table.
      writes ChargeMeasures · reads AccountDeltaTransformChargeTransformChargeTransactionMeasure
      ↳ feeds from Augment AccountDelta ReprocessChangedConfigurations
    4. LoadAccountDataLoadAccountData
      Imports historical billing data from external systems into core account tables while preserving manual user modifications and application fields.
      · reads AccountChargeAccountDeltaChargeMeasuresChargeTypeInsuranceMapPatientProviderSourcePatientInsurance
      ↳ feeds from Augment AccountDelta ReprocessChangedConfigurations, Load ChargeMeasures
      custom account charge querycustom account querycustom account remit querycustom account insurance query
    5. ▶Load-Custom-Propertiessub-job · 2↗
      1. Load Claim ID Custom PropertyUpdateCustomPropertyFromQuery
        · reads AccountDeltaTransformAccount
        entity=Accountcustom property key=CustomProperty-[id]auto querybatch mode
      2. SyncBatchSyncBatch
        Synchronizes processed data from batch staging tables to production tables, updating visits, quotes, and custom property mappings.
        writes CustomPropertyMap · reads CustomPropertyMapBatch
        sync custom property map
    6. ▶Load-Dimension-Memberssub-job · 15↗
      1. Load Insurance Dimensionsqlload_dimension_members__load_insurance_dimension.sqldisabled
        ✨ Populates the insurance dimension with unique carrier keys to enable filtering and analysis by payer.
        writes DimensionMember · reads Insurance
      2. Load EligibilityInsurance Dimensionsqlload_dimension_members__load_eligibilityinsurance_dimension.sqldisabled
        ✨ Loads insurance members that support electronic eligibility and benefits verification via API integration.
        writes DimensionMember · reads DimensionMemberInsurance
      3. Load QuoteInsurance Dimensionsqlload_dimension_members__load_quoteinsurance_dimension.sqldisabled
        ✨ Builds a dimension of insurance providers associated with active contracts to facilitate accurate patient cost estimates.
        writes DimensionMember · reads ContractMapInsurance
      4. LoadInsuranceDimensionMembersLoadInsuranceDimensionMembers
        Synchronize insurance-specific dimension members from the insurance table to update contract and eligibility filtering options across the application.
        writes DimensionMember
        load insuranceload quote insuranceload eligibility insurance
      5. Load Time Dimensionssqlload_dimension_members__load_time_dimensions.sql
        ✨ Builds time dimension members for days, months, and years based on account service dates to enable temporal reporting.
        writes DimensionMember · reads TransformAccount
      6. Load VisitStatus Dimensionsqlload_dimension_members__load_visitstatus_dimension.sqldisabled
        ✨ Loads appointment status values into the visit status dimension to track patient encounter progress.
        writes DimensionMember · reads TransformVisit
      7. Load Provider Dimensionsqlload_dimension_members__load_provider_dimension.sql
        ✨ Updates provider and provider type dimensions with names and classifications to organize data by clinical staff.
        writes DimensionMember · reads Provider
      8. Load Facility Dimensionssqlload_dimension_members__load_facility_dimensions.sql
        ✨ Loads facility names and their associated groups into the dimension table to track services by location.
        writes DimensionMember · reads Facility
      9. Load FacilityGroup Dimensionsqlload_dimension_members__load_facilitygroup_dimension.sql
        ✨ Builds the facility group dimension by extracting unique parent identifiers from existing facility records.
        writes DimensionMember · reads DimensionMember
        ↳ feeds from Load DiagnosisCode Dimension, Load Facility Dimensions, Load FacilityType Dimension, Load PlaceOfService Dimension, Load Provider Dimension, Load State Dimensions, Load Time Dimensions, LoadInsuranceDimensionMembers
      10. Load FacilityType Dimensionsqlload_dimension_members__load_facilitytype_dimension.sql
        ✨ Loads facility type dimension members from facility records to enable standardized categorization across the revenue cycle pipeline.
        writes DimensionMember · reads Facility
      11. Load VisitType Dimensionssqlload_dimension_members__load_visittype_dimensions.sqldisabled
        ✨ Loads visit type dimension members from HL7 visit data to standardize appointment types for reporting and analysis.
        writes DimensionMember · reads HL7Visit
      12. Load SourceInsurance Dimensionssqlload_dimension_members__load_sourceinsurance_dimensions.sql
        ✨ Loads source insurance dimension members from insurance mapping data to track and categorize insurance plans used in patient accounts.
      13. Load PlaceOfService Dimensionsqlload_dimension_members__load_placeofservice_dimension.sql
        ✨ Loads place of service dimension members from transformed charge data to categorize where healthcare services were provided.
        writes DimensionMember · reads TransformCharge
      14. Load DiagnosisCode Dimensionsqlload_dimension_members__load_diagnosiscode_dimension.sql
        ✨ Loads unique diagnosis codes from charge records into the dimension member table to support standardized clinical reporting.
        writes DimensionMember · reads TransformCharge
      15. Load State Dimensionssqlload_dimension_members__load_state_dimensions.sql
        ✨ Updates state dimensions using facility location data to allow for geographic segmentation of healthcare services and revenue.
        writes DimensionMember · reads Facility
    7. ▶Score-Accountssub-job · 1↗
      1. Score All AccountsBatchProcessAccounts
        writes AccountEstimate · reads QuoteBatchVisitBatch
        incremental
  9. Load TempChargeRecoveryReportsqldaily_accounts_processing__load_tempchargerecoveryreport.sql
    ✨ Builds a temporary report comparing estimated and actual insurance payments to track recovered revenue from account appeals.
    writes TempChargeRecoveryReport · reads AccountAccountAppealStatusAccountAppealSummaryAccountChargeAccountEstimateChargeChargeTypeFacilityPatient
  10. Revfind-Contract-Modeling-Processingsub-job