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

Batch / file feed · RevFind pipeline

Commonwealth · Cutover-Daily-Accounts-Processing

Process Athena Accounts

pipeline Commonwealth/Cutover-Daily-Accounts-Processing · db Commonwealth_ProdMirror · updated 2026-05-20
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 02: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 - Commonwealth - Cutoverdaily at 02:30prod-db-3enabledstandalone

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

Cutover-Daily-Accounts-Processing

12 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. Wait For Dagster Pipeline Completesqlcutover_daily_accounts_processing__wait_for_dagster_pipeline_complete.sql
    ✨ Pauses the workflow until the external data pipeline signals completion to ensure data readiness for subsequent processing steps.
    · reads DagsterRunComplete
  2. ▶Cutover-Load-Athena-Data-ImportSqlsub-job · 44↗leaving this the same as the other Load-Athena-Data-ImportSql. We waste a bit of time loading the source tables, but this'll be very useful for if we need to swap back to the old daily processing and reload accounts
    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 SourceClinicalEncountersqlcutover_load_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 SourceAppointmentsqlcutover_load_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 SourceClaimsqlcutover_load_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 SourceTransactionsqlcutover_load_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 SourceTransactionChargesqlcutover_load_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 SourceTransactionPaymentsqlcutover_load_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 SourceTransactionAdjustmentsqlcutover_load_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 SourceTransactionTransfersqlcutover_load_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 SourceERABatchsqlcutover_load_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 SourceERARecordsqlcutover_load_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 SourceERADetailsqlcutover_load_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 SourceERAKicksqlcutover_load_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 SourceClaimNotesqlcutover_load_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 SourceDenialClaimNotesqlcutover_load_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 SourcePatientsqlcutover_load_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 SourcePayersqlcutover_load_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 SourcePatientInsurancesqlcutover_load_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 SourceProvidersqlcutover_load_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 SourceDepartmentsqlcutover_load_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 SourceFeeScheduleProceduresqlcutover_load_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 SourceProcedureCodesqlcutover_load_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 SourceFeeSchedulesqlcutover_load_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 SourceProcedureCodeModifiersqlcutover_load_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 SourceChargeMastersqlcutover_load_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
  3. ▶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
  4. ▶Cutover-Load-ChargeTypesub-job · 6↗Load the Charge Types from ChargeMaster + CPT Crosswalk Copy of other Load-ChargeType job, we're still creating chargetypes from source data the old fashioned way here.
    1. Load-ImportChargeTypesqlcutover_load_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-ChargeTypesqlcutover_load_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-DimensionMembersqlcutover_load_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-DimensionMembersqlcutover_load_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
  5. ▶Cutover-Load-Account-Transform-Tablessub-job · 12↗We only need TransformPatient, everything else is handled by dagster
    1. Check AccountDeltasqlcutover_load_account_transform_tables__check_accountdelta.sqldisabled
      ✨ Ensures the account delta table exists with the correct schema, including necessary columns and indexes for tracking changed records.
      · reads AccountDelta
    2. Create AccountDeltasqlcutover_load_account_transform_tables__create_accountdelta.sqldisabled
      ✨ 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 Visitssqlcutover_load_account_transform_tables__load_transformtransaction_updated_for_claims_sans_visits.sqldisabled
      ✨ Standardizes and loads financial transaction data, including payments and adjustments, for updated accounts into the transaction transformation table.
      writes TransformTransaction · reads AccountDeltaSourceClaimSourcePatientInsuranceSourceTransactionsourceclaimnote
    4. Load TransformRemitAdjustment - Updated for Claims sans Visitssqlcutover_load_account_transform_tables__load_transformremitadjustment_updated_for_claims_sans_visits.sqldisabled
      ✨ Processes and loads remittance adjustment details, including denial categories and group codes, from electronic remittance advice into the transformation table.
      writes TransformRemitAdjustment · reads AccountDeltaAdjustmentCodeRollupSourceClaimSourceERABatchSourceERADetailSourceERAKickSourceERARecordSourcePatientInsurance
    5. Load TransformCharge - Updated for Claims sans Visitssqlcutover_load_account_transform_tables__load_transformcharge_updated_for_claims_sans_visits.sqldisabled
      ✨ Transforms and loads charge-level details, including procedure codes, modifiers, and diagnosis information, for updated accounts into the charge table.
      writes TransformCharge · reads AccountDeltaSourceClaimSourceDepartmentSourceTimesheetEntryTransactionSourceTransactionSourceTransactionCharge
    6. Load TransformAccount - Updated for Claims sans Visitssqlcutover_load_account_transform_tables__load_transformaccount_updated_for_claims_sans_visits.sqldisabled
      ✨ Builds unified account records by merging clinical encounter and billing claim data for comprehensive financial tracking.
      writes TransformAccount · reads AccountDeltaSourceClaimSourceClinicalEncounterSourceDepartmentSourcePatientInsuranceSourceProvider
    7. Load TransformRemitAdjustmentAggregatesqlcutover_load_account_transform_tables__load_transformremitadjustmentaggregate.sqldisabled
      ✨ Aggregates insurance remittance adjustments and denial categories to summarize payment impacts at the encounter level.
      writes TransformRemitAdjustmentAggregate · reads AccountDeltaTransformChargeTransformRemitAdjustment
    8. Load TransformChargeTransactionMeasuressqlcutover_load_account_transform_tables__load_transformchargetransactionmeasures.sqldisabled
      ✨ Calculates total financial measures per charge, including payments, adjustments, and denials, for detailed revenue analysis.
      writes TransformChargeTransactionMeasure · reads AccountDeltaTransformChargeTransformRemitAdjustmentAggregateTransformTransaction
    9. Load TransformPatientsqlcutover_load_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 TransformPatientInsurancesqlcutover_load_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)MergeSqldisabled
      writes TransformPatientInsurance · reads InsuranceMapSourcePatientInsuranceSourcePayer
      merge data source type=ThisDatabasetable name=TransformPatientInsurancemerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
  6. ▶Load-Patients-Entitysub-job · 1↗
    1. Execute LoadPatientsLoadPatients
      Upsert patient records into the patient dimension.
      · reads PatientTransformPatient
      custom patient query
  7. ▶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
  8. ▶Cutover-Load-Batch-Dimension-Memberssub-job · 1↗we're creating the modifier dimensionmember in dagster merging like we used to but just pulling the precomputed dim member
    1. Load Modifier Dimensionsqlcutover_load_batch_dimension_members__load_modifier_dimension.sql
      ✨ Loads modifier dimension members into the master dimension table to support reporting and filtering within the pipeline.
      writes DimensionMember · reads StagingDimensionMember
  9. ▶Cutover-Load-Account-Datasub-job · 7↗Load Account-Level Tables (click to read more) We no longer need the reprocesschangedconfigurations, insurance map changes will show up in the dagster delta. When we create the Staging tables that feed into the LoadAccountQueries we will see these mapping differences will result
    1. Augment AccountDeltaReprocessChangedConfigsdisabled
      reprocess accountsDISABLED
    2. Augment AccountDelta ReprocessChangedConfigurationssqlcutover_load_account_data__augment_accountdelta_reprocesschangedconfigurations.sqldisabled
      ✨ Adds accounts requiring reprocessing due to configuration changes into the account delta table for downstream processing.
      writes AccountDelta · reads AccountDeltaAccountsToReprocessTransformAccount
    3. Load ChargeMeasuressqlcutover_load_account_data__load_chargemeasures.sqldisabled
      ✨ Calculates and loads financial metrics like payments, adjustments, and denials for specific accounts into the charge measures table.
      writes ChargeMeasures · reads AccountDeltaTransformChargeTransformChargeTransactionMeasure
    4. LoadAccountDataLoadAccountData
      Imports historical billing data from external systems into core account tables while preserving manual user modifications and application fields.
      · reads PatientStagingAccountStagingAccountChargeStagingAccountInsuranceStagingAccountRemit
      custom account charge querycustom account querycustom account remit querycustom account insurance query
    5. ▶Cutover-Load-Custom-Propertiessub-job · 2↗We'll be moving the logic of this custom property load to dagster to make a custom property asset. We'll sync that table to a staging table and load the precomputed values instead
      1. Load Claim ID Custom PropertyUpdateCustomPropertyFromQuery
        · reads StagingAccountStagingAccountChargeStagingAccountInsuranceStagingAccountRemitStagingCustomPropertyMember
        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. ▶Cutover-Load-Dimension-Memberssub-job · 15↗time dimenison, place of service, diagnosis code all read from transform tables only used in dagster. We'll construct those there, and read in the same way as we read custom properties
      1. Load Insurance Dimensionsqlcutover_load_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 Dimensionsqlcutover_load_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 Dimensionsqlcutover_load_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 Dimensionssqlcutover_load_dimension_members__load_time_dimensions.sql
        ✨ Synchronizes time-based dimensions for days, months, and years to support temporal reporting and trend analysis.
        writes DimensionMember · reads StagingDimensionMember
      6. Load VisitStatus Dimensionsqlcutover_load_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 Dimensionsqlcutover_load_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 Dimensionssqlcutover_load_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 Dimensionsqlcutover_load_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 Dimensionsqlcutover_load_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 Dimensionssqlcutover_load_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 Dimensionssqlcutover_load_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 Dimensionsqlcutover_load_dimension_members__load_placeofservice_dimension.sql
        ✨ Loads place of service dimension members from staging tables to maintain consistent location data for billing and reporting.
        writes DimensionMember · reads StagingDimensionMember
      14. Load DiagnosisCode Dimensionsqlcutover_load_dimension_members__load_diagnosiscode_dimension.sql
        ✨ Loads diagnosis code dimension members from staging tables to ensure standardized medical coding for claims and cost estimates.
        writes DimensionMember · reads StagingDimensionMember
      15. Load State Dimensionssqlcutover_load_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
  10. Load TempChargeRecoveryReportsqlcutover_daily_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
  11. Revfind-Contract-Modeling-Processingsub-job
  12. Mark Pipeline Completesqlcutover_daily_accounts_processing__mark_pipeline_complete.sql
    ✨ Records the completion timestamp of the account data load to coordinate future incremental data updates.
    writes LoadAccountComplete