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

sub-job

EugeneGI · Load-Visits-Load-Batch

called by HL7-Processing-Nightly

sub-job EugeneGI/Load-Visits-Load-Batch · db EugeneGI_ProdMirror · updated 2026-03-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

Load-Visits-Load-Batch

4 tasks · EugeneGI
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 TempBatchVisitsqlload_visits_load_batch__load_tempbatchvisit.sqldisabled
    ✨ Initializes the temporary batch table by identifying visits and insurance combinations that require eligibility verification based on business rules.
    writes TempBatchVisit · reads DimensionMemberEligibilityTxnTransformVisitTransformVisitInsuranceTransformVisitInsuranceCoverageStatusVisit
  2. Augment Visit Deltasqlload_visits_load_batch__augment_visit_delta.sqldisabled
    ✨ Adds visit records requiring new insurance eligibility lookups to the change tracking table for processing.
    writes VisitDelta · reads TempBatchVisitVisitDelta
  3. LoadVisitBatchLoadVisitBatch
    Load scheduled visits and associated charges into the processing pipeline using custom SQL queries for pricing estimation and quote generation.
    writes QuoteBatchVisitBatch · reads InsuranceMapPatientTransformVisitTransformVisitInsuranceVisitVisitDelta
    custom visit queryauto charge queryauto service type querycustom coverage queryadd zero charge
  4. ▶Flow-MM-HL7-Processing-CustomPropertysub-job · 8↗
    1. Load Primary Coverage StatusUpdateCustomPropertyFromQuery
      · reads TransformVisitInsuranceCoverageStatusVisitBatch
      entity=Visitcustom property key=PrimaryCoverageStatuscustom querybatch mode
    2. Load Secondary Coverage StatusUpdateCustomPropertyFromQuery
      · reads TransformVisitInsuranceCoverageStatusVisitBatch
      entity=Visitcustom property key=SecondaryCoverageStatuscustom querybatch mode
    3. Load Tertiary Coverage StatusUpdateCustomPropertyFromQuery
      · reads TransformVisitInsuranceCoverageStatusVisitBatch
      entity=Visitcustom property key=TertiaryCoverageStatuscustom querybatch mode
    4. LoadCustomNotesCustomPropertyLoadCustomNotesCustomProperty
      · reads BundleNotesMappingHL7VisitVisitBatch
      entity=Visitcustom property key=CustomNotescustom querybatch mode
    5. LoadPriorAuthCustomPropertyLoadPriorAuthCustomProperty
      · reads CustomPropertyMapTransformVisitInsuranceVisitbatchsourcepriorauthdetails
      entity=Visitcustom property key=PriorAuthcustom querybatch mode
    6. LoadMedicaidRolloverCustomPropertyLoadMedicaidRolloverCustomProperty
      · reads CustomPropertyMapTransformVisitInsuranceVisitBatch
      entity=Visitcustom property key=MedicaidRollovercustom querybatch mode
    7. Load Has Active Medicaid/Medicare InsuranceUpdateCustomPropertyFromQuery
      · reads DimensionMemberTransformVisitInsuranceCoverageStatusVisitBatch
      entity=Visitcustom property key=HasActiveMedicaid/MedicareInsurancecustom querybatch mode
    8. Update HasMisMatchedMemberID Custom Property after recheckUpdateCustomPropertyFromQuery
      · reads BatchVisitEligibilityEligibilityTxnVisitBatch
      entity=Visitcustom property key=HasMismatchedMemberIDcustom querybatch mode