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

sub-job

ECP · Process-Snowflake-Data-Load-RevFind-ImportSQL

Download and process the snowflake data into source tables

called by Daily-Accounts-Processing-RevFind

sub-job ECP/Process-Snowflake-Data-Load-RevFind-ImportSQL · db ECP_ProdMirror · updated 2025-11-27

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

Process-Snowflake-Data-Load-RevFind-ImportSQL

29 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. Snowflake required transaction isolation levelsqlprocess_snowflake_data_load_revfind_importsql__snowflake_required_transaction_isolation_level.sqldisabled
    ✨ Sets the transaction isolation level to ensure data consistency during the Snowflake import process.
  2. ImportBillingEntityImportBillingEntity
    Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
    writes ImportBillingEntity
    connection string={SnowflakeConnectionString}table name=ImportBillingEntityimport mode=Replacedata source type=Snowflake
  3. ImportChargeMasterImportChargeMaster
    Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
    writes ImportChargeMaster
    connection string={SnowflakeConnectionString}table name=ImportChargeMasterimport mode=Replacedata source type=Snowflake
  4. ImportPayersImportPayers
    Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
    writes ImportPayers
    connection string={SnowflakeConnectionString}table name=ImportPayersimport mode=Replacedata source type=Snowflake
  5. ImportProvidersImportProviders
    Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
    writes ImportProviders
    connection string={SnowflakeConnectionString}table name=ImportProvidersimport mode=Replacedata source type=Snowflake
  6. ImportLocationMapImportLocationMap
    Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
    writes ImportLocationMap
    connection string={SnowflakeConnectionString}table name=ImportLocationMapimport mode=Replacedata source type=Snowflake
  7. ImportLocationImportLocation
    Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
    writes ImportLocation
    connection string={SnowflakeConnectionString}table name=ImportLocationimport mode=Replacedata source type=Snowflake
  8. ImportPatientsImportPatients
    Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
    writes ImportPatients
    connection string={SnowflakeConnectionString}table name=ImportPatientsimport mode=Replacedata source type=Snowflake
  9. ImportPatientInsuranceImportPatientInsurance
    Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
    writes ImportPatientInsurance
    connection string={SnowflakeConnectionString}table name=ImportPatientInsuranceimport mode=Replacedata source type=Snowflake
  10. ImportClaimsImportClaims
    Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
    writes ImportClaims
    connection string={SnowflakeConnectionString}table name=ImportClaimsimport mode=Replacedata source type=Snowflake
  11. ImportEncountersImportEncounters
    Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
    writes ImportEncounters
    connection string={SnowflakeConnectionString}table name=ImportEncountersimport mode=Replacedata source type=Snowflake
  12. ImportEncounterInsuranceImportEncounterInsurance
    Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
    writes ImportEncounterInsurance
    connection string={SnowflakeConnectionString}table name=ImportEncounterInsuranceimport mode=Replacedata source type=Snowflake
  13. ImportChargesImportCharges
    Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
    writes ImportCharges
    connection string={SnowflakeConnectionString}table name=ImportChargesimport mode=Replacedata source type=Snowflake
  14. ImportAdjustmentsImportAdjustments
    Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
    writes ImportAdjustments
    connection string={SnowflakeConnectionString}table name=ImportAdjustmentsimport mode=Replacedata source type=Snowflake
  15. ImportPaymentsImportPayments
    Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
    writes ImportPayments
    connection string={SnowflakeConnectionString}table name=ImportPaymentsimport mode=Replacedata source type=Snowflake
  16. ImportRefundsImportRefunds
    Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.
    writes ImportRefunds
    connection string={SnowflakeConnectionString}table name=ImportRefundsimport mode=Replacedata source type=Snowflake
  17. Process-to-SourceBillingEntitysqlprocess_snowflake_data_load_revfind_importsql__process_to_sourcebillingentity.sql
    ✨ Loads billing entity and practice configuration data from the import staging area into the source system tables.
    writes SourceBillingEntity · reads ImportBillingEntity
    ↳ feeds from ImportBillingEntity
  18. Process-to-SourceChargeMastersqlprocess_snowflake_data_load_revfind_importsql__process_to_sourcechargemaster.sql
    ✨ Loads service item prices and CPT codes from the import staging area into the source charge master table.
    writes SourceChargeMaster · reads ImportChargeMaster
    ↳ feeds from ImportChargeMaster
  19. Process-to-SourcePayerssqlprocess_snowflake_data_load_revfind_importsql__process_to_sourcepayers.sql
    ✨ Loads payer information from the import table into the source payer repository to support insurance identification.
    writes SourcePayers · reads ImportPayers
    ↳ feeds from ImportPayers
  20. Process-to-SourceProviderssqlprocess_snowflake_data_load_revfind_importsql__process_to_sourceproviders.sql
    ✨ Loads unique provider details from the import table into the source provider repository for clinical and billing attribution.
    writes SourceProvider · reads ImportProviders
    ↳ feeds from ImportProviders
  21. Process-to-SourceLocationMapsqlprocess_snowflake_data_load_revfind_importsql__process_to_sourcelocationmap.sql
    ✨ Updates or inserts location mapping data to ensure consistent facility identification across different source systems.
    writes SourceLocationMap · reads ImportLocationMap
    ↳ feeds from ImportLocationMap
  22. Process-to-SourceLocationsqlprocess_snowflake_data_load_revfind_importsql__process_to_sourcelocation.sql
    ✨ Synchronizes facility location data while applying place-of-service crosswalks to maintain accurate site-of-care records.
  23. Process-to-SourcePatientsqlprocess_snowflake_data_load_revfind_importsql__process_to_sourcepatient.sql
    ✨ Refreshes patient demographic records by replacing existing entries with updated information from the latest import data.
    writes SourcePatient · reads ImportPatients
    ↳ feeds from ImportPatients
  24. Process-to-SourcePatientInsurancesqlprocess_snowflake_data_load_revfind_importsql__process_to_sourcepatientinsurance.sql
    ✨ Updates patient insurance coverage details by replacing existing records with current policy and payer information.
    writes SourcePatientInsurance · reads ImportPatientInsurance
    ↳ feeds from ImportPatientInsurance
  25. Process-to-SourceClaimsqlprocess_snowflake_data_load_revfind_importsql__process_to_sourceclaim.sql
    ✨ Refreshes claim data by replacing existing records with updated billing, diagnosis, and payment information from the source system.
    writes SourceClaim · reads ImportClaims
    ↳ feeds from ImportClaims
  26. Process-to-SourceEncountersqlprocess_snowflake_data_load_revfind_importsql__process_to_sourceencounter.sql
    ✨ Updates clinical encounter records by replacing existing entries with the latest visit, provider, and billing status data.
    writes SourceEncounter · reads ImportEncounters
    ↳ feeds from ImportEncounters
  27. Process-to-SourceEncounterInsurancesqlprocess_snowflake_data_load_revfind_importsql__process_to_sourceencounterinsurance.sql
    ✨ Updates the source encounter insurance table by replacing existing records with newly imported data.
    writes SourceEncounterInsurance · reads ImportEncounterInsurance
    ↳ feeds from ImportEncounterInsurance
  28. Process-to-SourceChargesqlprocess_snowflake_data_load_revfind_importsql__process_to_sourcecharge.sql
    ✨ Cleans charge modifiers and refreshes the source charge table with updated billing and service item data.
    writes SourceCharge · reads ImportChargesic
    ↳ feeds from ImportCharges
  29. Process-to-SourceTransactionsqlprocess_snowflake_data_load_revfind_importsql__process_to_sourcetransaction.sql
    ✨ Synchronizes the source transaction table by importing and updating adjustment and payment records from the staging tables.
    writes SourceTransaction · reads ImportAdjustmentsImportPaymentsImportRefunds
    ↳ feeds from ImportAdjustments, ImportPayments, ImportRefunds