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

sub-job

Commonwealth · Cutover-Load-Account-Data

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 in those accounts automatically getting added to the delta

called by Cutover-Daily-Accounts-Processing

sub-job Commonwealth/Cutover-Load-Account-Data · db Commonwealth_ProdMirror · updated 2026-05-22

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

Cutover-Load-Account-Data

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