All cardiology pipelines run in backend-analysis and are dispatched asynchronously. List live definitions and parameter schemas:
curl http://localhost:8001/pipelines
ECG
| Pipeline | Input | Outputs |
|---|
preprocess_ecg | WFDB, CSV, or EDF waveform | R-peaks, RR intervals, SQI, artifact rate, waveform preview |
compute_hrv | Preprocess run, RR artifact, or RR CSV upload | Time, frequency, nonlinear HRV metrics |
full_ecg_analysis | WFDB, CSV, or EDF waveform | Chained preprocess + HRV in one run |
compute_arrhythmia_burden | RR intervals from preprocess | Irregularity %, pause burden, beat flags |
RR-only
| Pipeline | Input | Outputs |
|---|
compute_hrv | RR CSV (format=rr_csv) | HRV metrics without waveform preprocess |
PPG
| Pipeline | Input | Outputs |
|---|
preprocess_ppg | PPG waveform | Pulse peaks, IBI intervals, quality, preview |
compute_prv | PPG preprocess run | Pulse rate variability metrics |
Blood pressure
| Pipeline | Input | Outputs |
|---|
analyze_bp | BP CSV | SBP/DBP/MAP means, variability, dipping classification |
Respiration and coupling
| Pipeline | Input | Outputs |
|---|
analyze_respiration | Respiration channel | Rate, breath timing, quality |
compute_rsa | ECG preprocess + respiration run | Respiratory sinus arrhythmia metrics |
compute_baroreflex | HRV/RR run + BP run | Baroreflex sensitivity (sequence method) |
Cohort
| Pipeline | Input | Outputs |
|---|
cohort_summary | Study subjects with completed HRV | Group means, SDs, p-values, plot series |
compute_risk_scores | Cohort with outcomes metadata | Research-only signal-derived stratification |
Batch jobs (POST /jobs/batch) run any registered pipeline across multiple datasets in one request.
Interpretation and reporting
| Pipeline | Input | Outputs |
|---|
interpret_results | Run ID(s) or cohort context | Descriptive or mechanistic narrative JSON |
generate_report | Study bundle | Report artifact with methods metadata |
Job lifecycle
pending → running → completed | failed
Poll status: GET /jobs/{run_id}
Generic dispatch: POST /jobs/run with pipeline_name and parameters JSON matching the pipeline schema.
Versioning
Every run records pipeline_version from the analysis service configuration. Include run IDs and versions in methods sections for reproducibility.