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

Batch / file feed · ClarityFlow pipeline

OneGI · Flow-ECW-Processing

Overall Processing job for HL7 pipeline

pipeline OneGI/Flow-ECW-Processing · db OneGI_ProdMirror · updated 2026-06-04
classification: flow · 10 Flow markers

trigger

How it's scheduled

Daily batch — once at 23:00

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 check eligibility, price the good-faith estimate, and send the patient letter. A tighter loop would just re-scan the same file.

Scheduled taskCadenceServerStateCoordination
\MDC\Daily - Processing - ONEGIdaily at 23:00prod-db-3enabledstandalone

shape

Against the canonical Flow spine

Every Flow pipeline is a variation on one shape. Lit stages are the ones this pipeline runs; the labels match the capability lens.

Ingest
Batch / file feed
→
Eligibility & benefits
EligibilityBenefitsDiscovery
→
Estimate
BundlesEstimate
→
Letters
LettersHL7
→
Work queue & sync
Work queueDashboardsSync

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

Coverage statusCPT / procedure logic

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

flow

Flow-ECW-Processing

9 tasks · OneGI
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. ▶Flow-ECW-Source-LoadDatasub-job · 16↗
    1. ▶Flow-Source-Load-ECW-AlertDatasub-job · 1↗
      1. ProcessDataFileProcessDataFile
        Import delimited files by automatically detecting their structure and merging the data into source tables.
        writes ImportECWAlertDataSourceECWAlertData
        file path={FilePath}archive directory=D:\ClientData\OneGI\ECW\RevFind\Archivebase table name=ECWAlertDatarow terminator=Newline
    2. ▶Flow-Source-Load-ECW-ClinicalAlertssub-job · 1↗
      1. ProcessDataFileProcessDataFile
        Import delimited files by automatically detecting their structure and merging the data into source tables.
        writes ImportECWClinicalAlertsSourceECWClinicalAlerts
        file path={FilePath}archive directory={SourceDataArchiveECW}base table name=ECWClinicalAlertsrow terminator=Newline
    3. ▶Flow-Source-Load-ECW-CurrentOfficeVisitNotesub-job · 3↗
      1. ProcessDataFileProcessDataFiledisabled
        Import delimited files by automatically detecting their structure and merging the data into source tables.
        writes ImportECWCurrentOfficeVisitNoteSourceECWCurrentOfficeVisitNote
        file path={FilePath}archive directory={SourceDataArchiveECW}base table name=ECWCurrentOfficeVisitNoterow terminator=NewlineDISABLED
      2. LoadDataFileLoadDataFile
        Imports delimited data files into database tables using predefined specifications for validation, loading, and optional file archiving.
        writes ImportECWCurrentOfficeVisitNote
        data file spec=ImportECWCurrentOfficeVisitNotefile path={FilePath}import mode=Replacearchive file path={SourceDataArchiveECW}
      3. ExecuteMergeSqlExecuteMergeSql
        Synchronizes data from external sources into target tables by performing batched insert, update, and delete operations based on keys.
        writes SourceECWCurrentOfficeVisitNote · reads ImportECWCurrentOfficeVisitNote
        ↳ feeds from LoadDataFile
        merge data source type=ThisDatabasetable name=SourceECWCurrentOfficeVisitNotemerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
    4. ▶Flow-Source-Load-ECW-Encountersub-job · 1↗
      1. ProcessDataFileProcessDataFile
        Import delimited files by automatically detecting their structure and merging the data into source tables.
        writes ImportECWEncounterSourceECWEncounter
        file path={FilePath}archive directory={SourceDataArchiveECW}base table name=ECWEncounterrow terminator=Newline
    5. ▶Flow-Source-Load-ECW-FlowPatientInsurancesub-job · 1↗
      1. ProcessDataFileProcessDataFile
        Import delimited files by automatically detecting their structure and merging the data into source tables.
        writes ImportECWFlowPatientInsuranceSourceECWFlowPatientInsurance
        file path={FilePath}archive directory={SourceDataArchiveECW}base table name=ECWFlowPatientInsurancerow terminator=Newline
    6. ▶Flow-Source-Load-ECW-FlowPatientssub-job · 2↗
      1. ExecuteProcessExecuteProcess
        command=powershell.exe
      2. ProcessDataFileProcessDataFile
        Import delimited files by automatically detecting their structure and merging the data into source tables.
        writes ImportECWFlowPatientsSourceECWFlowPatients
        file path={FilePath}archive directory={SourceDataArchiveECW}base table name=ECWFlowPatientsrow terminator=Newline
    7. ▶Flow-Source-Load-ECW-HistoryPresentIllnesssub-job · 3↗
      1. ProcessDataFileProcessDataFiledisabled
        Import delimited files by automatically detecting their structure and merging the data into source tables.
        writes ImportECWHistoryPresentIllnessSourceECWHistoryPresentIllness
        file path={FilePath}archive directory={SourceDataArchiveECW}base table name=ECWHistoryPresentIllnessrow terminator=NewlineDISABLED
      2. LoadDataFileLoadDataFile
        Imports delimited data files into database tables using predefined specifications for validation, loading, and optional file archiving.
        writes ImportECWHistoryPresentIllness
        data file spec=ImportECWHistoryPresentIllnessfile path={FilePath}import mode=Replacearchive file path={SourceDataArchiveECW}
      3. ExecuteMergeSqlExecuteMergeSql
        Synchronizes data from external sources into target tables by performing batched insert, update, and delete operations based on keys.
        writes SourceECWHistoryPresentIllness · reads ImportECWHistoryPresentIllness
        ↳ feeds from LoadDataFile
        merge data source type=ThisDatabasetable name=SourceECWHistoryPresentIllnessmerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
    8. ▶Flow-Source-Load-ECW-LastOfficeVisitNotesub-job · 1↗
      1. ProcessDataFileProcessDataFile
        Import delimited files by automatically detecting their structure and merging the data into source tables.
        writes ImportECWLastOfficeVisitNoteSourceECWLastOfficeVisitNote
        file path={FilePath}archive directory={SourceDataArchiveECW}base table name=ECWLastOfficeVisitNoterow terminator=Newline
    9. ▶Flow-Source-Load-ECW-Orderssub-job · 1↗
      1. ProcessDataFileProcessDataFile
        Import delimited files by automatically detecting their structure and merging the data into source tables.
        writes ImportECWOrdersSourceECWOrders
        file path={FilePath}archive directory={SourceDataArchiveECW}base table name=ECWOrdersrow terminator=Newline
    10. ▶Flow-Source-Load-ECW-PriorDiagnosissub-job · 4↗
      1. ProcessDataFileProcessDataFiledisabled
        Import delimited files by automatically detecting their structure and merging the data into source tables.
        writes ImportECWPriorDiagnosisSourceECWPriorDiagnosis
        file path={FilePath}archive directory={SourceDataArchiveECW}base table name=ECWPriorDiagnosisrow terminator=NewlineDISABLED
      2. ExecuteProcessExecuteProcess
      3. LoadDataFileLoadDataFile
        Imports delimited data files into database tables using predefined specifications for validation, loading, and optional file archiving.
        writes ImportECWPriorDiagnosis
        data file spec=ImportECWPriorDiagnosisfile path={FilePath}import mode=Replacearchive file path={SourceDataArchiveECW}
      4. ExecuteMergeSqlExecuteMergeSql
        Synchronizes data from external sources into target tables by performing batched insert, update, and delete operations based on keys.
        writes SourceECWPriorDiagnosis · reads ImportECWPriorDiagnosis
        ↳ feeds from LoadDataFile
        merge data source type=ThisDatabasetable name=SourceECWPriorDiagnosismerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
    11. ▶Flow-Source-Load-ECW-ProblemListsub-job · 4↗
      1. ProcessDataFileProcessDataFiledisabled
        Import delimited files by automatically detecting their structure and merging the data into source tables.
        writes ImportECWProblemListSourceECWProblemList
        file path={FilePath}archive directory={SourceDataArchiveECW}base table name=ECWProblemListrow terminator=NewlineDISABLED
      2. ExecuteProcessExecuteProcess
      3. LoadDataFileLoadDataFile
        Imports delimited data files into database tables using predefined specifications for validation, loading, and optional file archiving.
        writes ImportECWProblemList
        data file spec=ImportECWProblemListfile path={FilePath}import mode=Replacearchive file path={SourceDataArchiveECW}
      4. ExecuteMergeSqlExecuteMergeSql
        Synchronizes data from external sources into target tables by performing batched insert, update, and delete operations based on keys.
        writes SourceECWProblemList · reads ImportECWProblemList
        ↳ feeds from LoadDataFile
        merge data source type=ThisDatabasetable name=SourceECWProblemListmerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
    12. ▶Flow-Source-Load-ECW-Referralsub-job · 4↗
      1. ProcessDataFileProcessDataFiledisabled
        Import delimited files by automatically detecting their structure and merging the data into source tables.
        writes ImportECWReferralSourceECWReferral
        file path={FilePath}archive directory={SourceDataArchiveECW}base table name=ECWReferralrow terminator=NewlineDISABLED
      2. ExecuteProcessExecuteProcess
      3. LoadDataFileLoadDataFile
        Imports delimited data files into database tables using predefined specifications for validation, loading, and optional file archiving.
        writes ImportECWReferral
        data file spec=ImportECWReferralfile path={FilePath}import mode=Replacearchive file path={SourceDataArchiveECW}
      4. ExecuteMergeSqlExecuteMergeSql
        Synchronizes data from external sources into target tables by performing batched insert, update, and delete operations based on keys.
        writes SourceECWReferral · reads ImportECWReferral
        ↳ feeds from LoadDataFile
        merge data source type=ThisDatabasetable name=SourceECWReferralmerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
    13. ▶Flow-Source-Load-ECW-VisitCodessub-job · 1↗
      1. ProcessDataFileProcessDataFile
        Import delimited files by automatically detecting their structure and merging the data into source tables.
        writes ImportECWVisitCodesSourceECWVisitCodes
        file path={FilePath}archive directory={SourceDataArchiveECW}base table name=ECWVisitCodesrow terminator=Newline
    14. ▶Flow-Source-Load-ECW-VisitStatussub-job · 2↗
      1. ProcessDataFileProcessDataFile
        Import delimited files by automatically detecting their structure and merging the data into source tables.
        writes ImportECWVisitStatusSourceECWVisitStatus
        file path={FilePath}archive directory={SourceDataArchiveECW}base table name=ECWVisitStatusrow terminator=Newline
      2. Remove NUL - ExecuteSqlsqlflow_source_load_ecw_visitstatus__remove_nul_executesql.sql
        ✨ Cleanses visit status data by removing null characters to ensure data integrity and prevent processing errors.
        · reads SourceECWVisitStatus
        ↳ feeds from ProcessDataFile
    15. ▶Flow-Source-Load-ECW-AscProcEncsub-job · 1↗
      1. ProcessDataFileProcessDataFile
        Import delimited files by automatically detecting their structure and merging the data into source tables.
        writes ImportECWAscProcEncSourceECWAscProcEnc
        file path={FilePath}archive directory={SourceDataArchiveECW}base table name=ECWAscProcEncrow terminator=Newline
    16. SourceECWColonoscopyType - ExecuteMergeSqlMergeSql
      writes CombinedDiagnosisCodesConsolidatedNotesEncounterFlagsPatientProblemsSourceECWColonoscopyType · reads SourceECWCurrentOfficeVisitNoteSourceECWEncounterSourceECWHistoryPresentIllnessSourceECWLastOfficeVisitNoteSourceECWProblemListSourceECWReferral
      merge data source type=ThisDatabasetable name=SourceECWColonoscopyTypemerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
  2. ▶Flow-ECW-LoadEntitiessub-job · 3↗Load Facility, Provider, Patients
    1. Load FacilityLoadEntities
      writes Facility · reads FacilitySourceECWFacilities
      entity type=Facilitycustom querykey prefix=F
    2. Merge ProvidersMergeSql
      writes Provider · reads SourceECWDoctorsTransformAccount
      merge data source type=ThisDatabasetable name=Providermerge mode=InsertUpdateSoftDeletebulk copy timeout seconds=300bulk copy use table lock
    3. Load PatientsLoadPatientsdisabled
      Upsert patient records into the patient dimension.
      · reads PatientTransformPatient
      custom patient queryDISABLED
  3. ▶Flow-ECW-Transformsub-job · 8↗EWC Transformation Layer
    1. TruncateVisitDeltasqlflow_ecw_transform__truncatevisitdelta.sql
      ✨ Clears the visit delta table to prepare for a fresh set of changed records in the current pipeline run.
      writes VisitDelta
    2. TransformPatientTransformPatient
      writes TransformPatient · reads SourceECWFlowPatients
      merge data source type=ThisDatabasetable name=TransformPatientmerge mode=InsertUpdateSoftDeletebulk copy timeout seconds=300bulk copy use table lock
    3. TransformPatientInsurance PatientDeltasqlflow_ecw_transform__transformpatientinsurance_patientdelta.sql
      ✨ Identifies patients with updated insurance information since the last processing time and loads them into the patient delta table.
      writes FlowPatientDelta · reads FlowLogLastProcessingTimeSourceECWFlowPatientInsurance
    4. Merge TransformPatientInsuranceMergeSql
      writes TransformPatientInsurance
      merge data source type=ThisDatabasetable name=TransformPatientInsurancemerge mode=InsertUpdateHardDeletebulk copy timeout seconds=300bulk copy use table lock
    5. TransformPatientInsurance VisitDeltasqlflow_ecw_transform__transformpatientinsurance_visitdelta.sql
      ✨ Adds future visits to the visit delta table for patients who have had recent insurance updates.
      writes VisitDelta · reads FlowPatientDeltaTransformVisit
      ↳ feeds from MergeTransformVisit, TransformPatientInsurance PatientDelta
    6. VisitDeltasqlflow_ecw_transform__visitdelta.sql
      ✨ Identifies new or updated encounters from source data and adds them to the visit delta table for processing.
      writes VisitDelta · reads FlowLogLastProcessingTimeSourceECWEncounterTransformVisitVisitDelta
      ↳ feeds from MergeTransformVisit, TransformPatientInsurance VisitDelta, TruncateVisitDelta
    7. MergeTransformVisitsqlflow_ecw_transform__mergetransformvisit.sql
      ✨ Transforms and loads encounter details like status, time, and provider into the transformed visit table for identified delta records.
      writes TransformVisit · reads FacilitySourceECWAscProcEncSourceECWColonoscopyTypeSourceECWEncounterSourceECWPatientsSourceECWReferralSourceECWVisitCodesSourceECWVisitStatus
      ↳ feeds from TransformPatientInsurance VisitDelta, TruncateVisitDelta, VisitDelta
    8. MergeTransformVisitInsurancesqlflow_ecw_transform__mergetransformvisitinsurance.sql
      ✨ Maps and loads patient insurance information into the transformed visit insurance table for visits identified in the delta set.
      writes TransformVisitInsurance · reads TransformPatientInsuranceTransformVisitVisitDelta
      ↳ feeds from Merge TransformPatientInsurance, MergeTransformVisit, TransformPatientInsurance VisitDelta, TruncateVisitDelta, VisitDelta
  4. LoadPatientsLoadPatientsdisabled
    Upsert patient records into the patient dimension.
    · reads FlowPatientDeltaPatientTransformPatient
    custom patient queryDISABLED
  5. ▶Flow-ECW-Processing-LoadDimensionMemberssub-job · 16↗
    1. LoadDimensionMembersLoadDimensionMembers
      Synchronize facility, provider, and insurance metadata into the dimension member table to refresh dashboard filters and reporting categories.
      writes DimensionMember
      load insuranceload quote insuranceload eligibility insuranceload facilityload provider
    2. Load Insurance Dimensionsqlflow_ecw_processing_loaddimensionmembers__load_insurance_dimension.sqldisabled
      ✨ Populates the insurance dimension with unique carrier keys to enable filtering and analysis by payer.
      writes DimensionMember · reads Insurance
    3. Load EligibilityInsurance Dimensionsqlflow_ecw_processing_loaddimensionmembers__load_eligibilityinsurance_dimension.sqldisabled
      ✨ Loads insurance members that support electronic eligibility and benefits verification via API integration.
      writes DimensionMember · reads DimensionMemberInsurance
    4. Load QuoteInsurance Dimensionsqlflow_ecw_processing_loaddimensionmembers__load_quoteinsurance_dimension.sqldisabled
      ✨ Builds a dimension of insurance providers associated with active contracts to facilitate accurate patient cost estimates.
      writes DimensionMember · reads ContractMapInsurance
    5. LoadInsuranceDimensionMembersLoadInsuranceDimensionMembersdisabled
      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 insuranceDISABLED
    6. Load Time Dimensionssqlflow_ecw_processing_loaddimensionmembers__load_time_dimensions.sql
      ✨ Populates time dimension hierarchies for days, months, and years using appointment timestamps to support temporal data analysis.
      writes DimensionMember · reads TransformVisit
    7. Load VisitStatus Dimensionsqlflow_ecw_processing_loaddimensionmembers__load_visitstatus_dimension.sql
      ✨ Builds the visit status dimension by extracting unique appointment statuses from transformed visit data.
      writes DimensionMember · reads TransformVisit
    8. Load Provider Dimensionsqlflow_ecw_processing_loaddimensionmembers__load_provider_dimension.sqldisabled
      ✨ Synchronizes provider details into the dimension member table to enable provider-based filtering and grouping in reports.
      writes DimensionMember · reads Provider
    9. Load Facility Dimensionssqlflow_ecw_processing_loaddimensionmembers__load_facility_dimensions.sqldisabled
      ✨ Builds facility and facility group hierarchies, linking clinics to their parent groups and tax identification numbers for financial reporting.
      writes DimensionMember · reads DimensionMemberFacilitysourceFacilityGroupToTIN
    10. Load VisitType Dimensionssqlflow_ecw_processing_loaddimensionmembers__load_visittype_dimensions.sql
      ✨ Builds and updates visit type dimension members using appointment types from transformed visit data.
      writes DimensionMember · reads TransformVisit
    11. Load Diagnosis Code Dimensionsqlflow_ecw_processing_loaddimensionmembers__load_diagnosis_code_dimension.sqldisabled
      ✨ Loads and updates the DiagnosisCode dimension by extracting unique primary, secondary, and tertiary diagnosis codes from charge data.
      writes DimensionMember · reads TransformCharge
    12. Load RadioIsotopes Code Dimensionsqlflow_ecw_processing_loaddimensionmembers__load_radioisotopes_code_dimension.sqldisabled
      ✨ Flags and updates the RadioIsotopes dimension to indicate the presence of radioisotope codes within the source risk data.
      writes DimensionMember · reads SourceCareRiskRadioIsotopeCodes
    13. Load Modifier Dimensionsqlflow_ecw_processing_loaddimensionmembers__load_modifier_dimension.sqldisabled
      ✨ Loads and updates the Modifier dimension by collecting unique modifier codes from multiple charge record fields.
      writes DimensionMember · reads TransformCharge
    14. Load Place of Service Dimensionsqlflow_ecw_processing_loaddimensionmembers__load_place_of_service_dimension.sqldisabled
      ✨ Builds and updates the PlaceOfService dimension using unique location codes extracted from charge transaction records.
      writes DimensionMember · reads TransformCharge
    15. Load SourceInsurance Dimensionsqlflow_ecw_processing_loaddimensionmembers__load_sourceinsurance_dimension.sqldisabled
      ✨ Loads and updates the SourceInsurance dimension with mapped insurance provider details for specific data sources and active accounts.
      writes DimensionMember · reads AccountInsuranceInsuranceMap
    16. Load State Dimensionssqlflow_ecw_processing_loaddimensionmembers__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
  6. ▶Flow-ECW-Processing-LoadVisitssub-job · 21↗
    1. Load TempBatchVisitsqlflow_ecw_processing_loadvisits__load_tempbatchvisit.sqldisabled
      ✨ Builds a temporary batch table to identify upcoming visits requiring initial or follow-up insurance eligibility and benefit verification.
      writes TempBatchVisitVisitEligServiceTypesVisitServiceTypes · reads DimensionMemberTempBatchVisitTransformVisitTransformVisitInsuranceTransformVisitInsuranceCoverageStatusVisitEligServiceTypesVisitServiceTypes
    2. Augment Visit Deltasqlflow_ecw_processing_loadvisits__augment_visit_delta.sqldisabled
      ✨ Updates the visit delta table by adding records flagged as requiring new insurance eligibility lookups from the batch process.
      writes VisitDelta · reads TempBatchVisitVisitDelta
    3. ReprocessChangedConfigurationsReprocessChangedConfigurationsdisabled
      Identify and queue visits or accounts affected by configuration changes to ensure historical data reflects updated pricing or insurance rules.
      reprocess visitsDISABLED
    4. Augment VisitDelta - ReprocessChangedConfigssqlflow_ecw_processing_loadvisits__augment_visitdelta_reprocesschangedconfigs.sqldisabled
      ✨ Updates insurance mappings for visits in the reprocess queue and adds new records to the visit delta table.
      writes VisitDeltaVisitKeyLookup · reads SourceOrganizationMMTransformVisitVisitDeltaVisitKeyLookup
    5. 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
      ↳ feeds from Sync Visits and Quotes
      custom visit queryauto charge queryauto service type querycustom coverage queryadd zero charge
    6. Flow-HL7-Processing-LoadCustomPropertiessub-jobdisabled
    7. AutoApplyBundlesToVisitBatchAutoApplyBundlesToVisitBatch
      Applies matching charge bundles to batch visits based on facility and insurance to ensure consistent pricing across service types.
    8. CheckBenefitsflow
      Verifies insurance eligibility and retrieves detailed benefits information for visits by making real-time API calls to insurance providers.
      auto query
    9. Re-Check Benefitsflowdisabled
      Verifies insurance eligibility and retrieves detailed benefits information for visits by making real-time API calls to insurance providers.
      · reads EligibilityStatusMapEligibilityTxnTempBatchVisitVisitBatch
      custom queryDISABLED
    10. AutoApplyBenefitsAutoApplyBenefits
      Populates insurance benefits like copays and deductibles on batch visits using data from eligibility verification transactions.
    11. CalculateVisitsflow
      Compute the good-faith estimate (CalculateVisits).
      · reads DimensionMemberVisitBatch
      ↳ feeds from LoadVisitBatch
      custom querycalculate chargesbatch mode
    12. AutoSendLettersAutoSendLettersdisabled
      Generates and sends patient cost estimate letters for visits in the batch table based on configured qualification and communication rules.
      DISABLED
    13. LogVisitChangeEventsBatchLogVisitChangeEventsBatch
      Compare batch visits against production records to detect and log specific property changes for auditing and compliance tracking.
    14. Load TransformVisitInsuranceCoverageStatussqlflow_ecw_processing_loadvisits__load_transformvisitinsurancecoveragestatus.sql
      ✨ Loads insurance coverage status by calculating the latest eligibility transaction results for visits in the current batch.
      writes TempEligibilityStatsTransformVisitInsuranceCoverageStatus · reads TempEligibilityStatsTransformVisitInsuranceVisitBatch
      ↳ feeds from LoadVisitBatch
    15. ▶Flow-MM-Processing-CustomPropertysub-job · 4↗
      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. Load Colonoscopy TypeUpdateCustomPropertyFromQuery
        · reads TransformVisitVisitBatch
        entity=Visitcustom property key=ColonoscopyTypecustom querybatch mode
    16. Sync Visits and QuotesSyncBatch
      Synchronizes processed data from batch staging tables to production tables, updating visits, quotes, and custom property mappings.
      writes CustomPropertyMapQuoteVisitVisitChangeEvent · reads CustomPropertyMapBatchQuoteBatchVisitBatchVisitChangeEventBatch
      ↳ feeds from LoadVisitBatch
      sync quotesync visitsync custom property mapsync visit change event
    17. ExportBatchVisitEligibilityflowdisabled
      Push the batch to the app / export results.
      · reads EligibilityTxnVisitBatch
      custom querytable name=BatchEligibility_Resultsarchive table name=BatchEligibility_ResultsArchiveDISABLED
    18. SearchForInsuranceflowdisabled
      Find coverage for visits missing insurance.
      · reads EligibilityTxnBatch
      custom querytable name=InsuranceSearch_Resultbatch modeDISABLED
    19. Generate-Reportsub-jobdisabled
    20. Load-Visit-Factsub-jobdisabled
    21. Update-Dashboard-Tablessub-jobdisabled
  7. Update HL7ProcessLogsqlflow_ecw_processing__update_hl7processlog.sql
    ✨ Updates the processing log with the current timestamp to track the last successful execution of the data flow.
    writes FlowLogLastProcessingTime
  8. WorkqueueAssignmentWorkqueueAssignment
    Assigns accounts or visits to workqueue stacks by evaluating matching criteria and updating item lists based on search terms.
  9. SendHL7Lettersflowdisabled
    Exports pending patient letters as HL7 messages with PDF attachments to a local directory for transmission to external systems.
    output file path=D:\ClientData\RIA\ORUpublish directory=D:\ClientData\RIA\ORUsending application=MDClaritysending facility=MDClarityreceiving application=Abbadox

markers

Why it classified as flow

Front-of-house actions found anywhere in the tree (including nested sub-jobs).

CalculateVisits
Compute the good-faith estimate
CheckBenefits
Real-time eligibility (270/271) benefit lookup
ExportBatchVisitEligibility
Export eligibility results
Load TransformVisitInsuranceCoverageStatus
ClarityFlow front-of-house step
LoadVisitBatch
ClarityFlow front-of-house step
SearchForInsurance
Insurance discovery for visits missing coverage
SendHL7Letters
Emit letters back over the HL7 interface
auto_apply_bundles
Apply procedure bundles for the estimate
auto_benefits
Auto-apply parsed benefits to visits
auto_send_letters
Send GFE / patient letters