Files
rarelens/pipeline/tests/conftest.py
Kemal Yaylali e76ae847a1 fix(science): stop scoring evidence that was never looked up
A review of the ranking's arithmetic found four things wrong, all of which
made the score look better informed than it was. Measurements below are from
this repo, not estimates.

**Components now abstain instead of inventing a number.** A run without a VEP
cache returns no allele frequencies, and rarity_score(None) read that as
"absent from gnomAD, therefore maximally rare" and awarded every variant a
free 0.25. jobs.has_frequencies / has_effect_scores record what the run
actually produced, absent components are dropped from the weighted mean, and
the remaining weights are renormalised so the score keeps its meaning. The UI
shows "not looked up" rather than a bar, and the funnel stops calling a step
"rare" when nothing was filtered.

**Allele frequency is no longer a model feature.** It dominated: the same
missense variant scored 0.887 at AF 0 and 0.0003 at AF 0.01. That double-
counted, because the ranking already scores frequency explicitly, putting
~45% of every rank on one measurement; and it was circular, because ACMG
assigns ClinVar's benign labels using frequency (BA1/BS1). Retraining without
it moves missense AUROC from 0.872 to 0.500 — exactly random. The old figure
was allele frequency, not variant-effect knowledge. The model therefore
abstains unless CADD or AlphaMissense is present, since otherwise it only
restates the consequence class.

**Phenotype matching is weighted by information content** and HPO annotations
are propagated up the ontology. Counting terms alike let "global
developmental delay" (IC 0.93) count as much as "dilated left subclavian
artery" (IC 7.88).

**A real bug in the propagation, found by checking it.** The ancestor walk
read a pre-order DFS backwards, which on a DAG lets a term resolve before one
of its parents and inherit that parent alone instead of its lineage. It
dropped 399 terms out of the phenotype branch, Camptodactyly and Chiari
malformation among them. Now a true post-order, tested against a reference
transitive closure.

The ontology arithmetic moved to rarelens_ml.hpo so it is covered by tests,
and rarelens_ml.benchmark measures the whole thing: across 10,178 published
cases the causal gene ranks first 45.9-81.0% of the time against 5,269 genes,
versus 0.02% for chance. docs/data.md reports that with its contamination
(HPO's annotations come from these same case reports), and includes the
measurement showing information-content weighting earns its place while
propagation does not - kept anyway, for a reason the docs argue rather than
assume.
2026-09-12 11:32:46 +01:00

63 lines
1.9 KiB
Python

"""Loader tests. DB tests use DATABASE_URL (CI's Postgres service) or a throwaway pgserver."""
import os
import sys
import tempfile
from collections.abc import Iterator
from pathlib import Path
import pytest
sys.path.insert(0, str(Path(__file__).resolve().parents[1] / "bin"))
# The subset of the Alembic schema (api/alembic/versions) that the loader writes to.
SCHEMA = """
CREATE TYPE jobstatus AS ENUM ('queued', 'running', 'succeeded', 'failed');
CREATE TABLE jobs (
id uuid PRIMARY KEY,
status jobstatus NOT NULL,
vep_version text,
has_frequencies boolean NOT NULL DEFAULT false,
has_effect_scores boolean NOT NULL DEFAULT false,
log text,
finished_at timestamptz
);
CREATE TABLE variants (
id serial PRIMARY KEY,
job_id uuid NOT NULL,
chrom text NOT NULL, pos integer NOT NULL, ref text NOT NULL, alt text NOT NULL,
gene text, consequence text, impact text, hgvsc text, hgvsp text,
gnomad_af double precision, clinvar_sig text, annotations jsonb NOT NULL
);
"""
_server = None
def _url() -> str | None:
global _server
if url := os.environ.get("DATABASE_URL"):
return url
try:
import pgserver
except ImportError:
return None
_server = pgserver.get_server(tempfile.mkdtemp(prefix="loader-pg-"), cleanup_mode="delete")
return "postgresql://postgres@/postgres?host=" + _server.get_uri().split("host=", 1)[1]
@pytest.fixture
def engine() -> Iterator:
url = _url()
if not url:
if os.environ.get("REQUIRE_DB"):
pytest.fail("REQUIRE_DB is set but no database is available")
pytest.skip("no DATABASE_URL and pgserver is not installed")
from load_db import engine_for
eng = engine_for(url)
with eng.begin() as conn:
conn.exec_driver_sql("DROP TABLE IF EXISTS variants, jobs; DROP TYPE IF EXISTS jobstatus")
conn.exec_driver_sql(SCHEMA)
yield eng
eng.dispose()