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

MDClarity · task primitives

Task reference

The typed task primitives the pipelines are built from — eligibility checks, letter senders, HL7/FHIR loaders, and more. Each is the full MDClarity task doc (docs/tasks/*.md). These are also linked inline from every pipeline's task tree.

AutoApplyBundlesToVisitBatch

Applies matching charge bundles to batch visits based on facility and insurance to ensure consistent pricing across service types.

task primitive
AutoBenefits

Populates insurance benefits like copays and deductibles on batch visits using data from eligibility verification transactions.

task primitive1 pipeline
AutoSendLetters

Generates and sends patient cost estimate letters for visits in the batch table based on configured qualification and communication rules.

task primitive1 pipeline
AutoSendLettersForFutureVisits

Generates and sends cost estimate letters for upcoming scheduled visits based on patient preferences and configured qualification criteria.

task primitive1 pipeline
AutoSendReminder

Resends patient cost estimate letters via email or SMS if they remain unviewed after a specified time interval.

task primitive
BatchProcessAccountData

Calculates patient account estimates across multiple facilities and insurance types to update pricing after contract or configuration changes.

task primitive
CheckBenefits

Verifies insurance eligibility and retrieves detailed benefits information for visits by making real-time API calls to insurance providers.

task primitive1 pipeline
CheckVisitGFEComplianceBatch

Audits Good Faith Estimate compliance for batch visits and identifies records requiring resends based on federal timing regulations.

task primitive
Download

Downloads files from remote FTP or SFTP servers to local directories with support for archiving and parallel transfers.

task primitive3 pipelines
ExecuteMergeSql

Synchronizes data from external sources into target tables by performing batched insert, update, and delete operations based on keys.

task primitive
ImportSql

Imports data from SQL Server or Snowflake queries into target tables using bulk copy operations with configurable loading modes.

task primitive
LoadAccountData

Imports historical billing data from external systems into core account tables while preserving manual user modifications and application fields.

task primitive
LoadDataFile

Imports delimited data files into database tables using predefined specifications for validation, loading, and optional file archiving.

task primitive
LoadDimensionMembers

Synchronize facility, provider, and insurance metadata into the dimension member table to refresh dashboard filters and reporting categories.

task primitive
LoadEntitiesFromQuery

Load or update entity records from custom SQL query results into their corresponding system tables using intelligent merge logic.

task primitive
LoadFeeSchedules

Generate time-based fee schedules from pricing records to establish effective date ranges for facility and insurance billing combinations.

task primitive
LoadHL7Files

Parses and imports patient demographics, visits, and charges from HL7 message files located in a specified directory.

task primitive5 pipelines
LoadInsuranceDimensionMembers

Synchronize insurance-specific dimension members from the insurance table to update contract and eligibility filtering options across the application.

task primitive
LoadVisits

Load scheduled visits and associated charges into the processing pipeline using custom SQL queries for pricing estimation and quote generation.

task primitive1 pipeline
LogVisitChangeEventsBatch

Compare batch visits against production records to detect and log specific property changes for auditing and compliance tracking.

task primitive
ProcessDataFile

Import delimited files by automatically detecting their structure and merging the data into source tables.

task primitive
ProcessScenarioModel

Calculates account estimates for queued scenario models to perform what-if analysis for contract modeling and pricing.

task primitive1 pipeline
ReprocessChangedConfigurations

Identify and queue visits or accounts affected by configuration changes to ensure historical data reflects updated pricing or insurance rules.

task primitive
ScanDataFile

Analyzes a delimited file's structure to automatically infer column definitions and save a reusable specification for future imports.

task primitive
SendHL7Letters

Exports pending patient letters as HL7 messages with PDF attachments to a local directory for transmission to external systems.

task primitive5 pipelines
SyncBatch

Synchronizes processed data from batch staging tables to production tables, updating visits, quotes, and custom property mappings.

task primitive1 pipeline
UpdateDashboardTables

Regenerates optimized aggregate tables for all dashboard reports and updates their definitions to reflect the latest source data.

task primitive4 pipelines
Upload

Uploads files from local directories to remote FTP or SFTP servers with optional post-transfer archiving and deletion.

task primitive
WorkqueueAssignment

Assigns accounts or visits to workqueue stacks by evaluating matching criteria and updating item lists based on search terms.

task primitive20 pipelines