ehr
Telemetry for background EHR query step outcomes.
Module
Functions
report_ehr_query_outcome
def report_ehr_query_outcome( *, run_outcome: str, ehr_availability: str | None, records_stored: int, skipped_total_failure: int, skipped_unidentified: int, skipped_fresh: int, task_hash: str,) ‑> None:Send an EHRQueryOutcomeEvent at a severity matching the outcome.
Never raises.
Arguments
run_outcome: The step'sEHRRunOutcomevalue.ehr_availability: What the preflight probe found, when one ran.records_stored: EHR rows the run persisted.skipped_total_failure: Patients served from an older row.skipped_unidentified: Patients with no identity to query by.skipped_fresh: Patients whose stored row was still fresh.task_hash: The step's partition.