tasks: motion: give warning if recording bus is stalled

This commit is contained in:
2026-03-27 22:39:42 +01:00
parent 8ff29caa6f
commit 8a3b2303a2

View File

@@ -37,6 +37,8 @@ pub async fn motion_task(src: DynamicReceiver<'static, Measurement>, prediction_
Measurement::SimulationProgress(source, duration, pct) => debug!("{source:?} simulation time: {} {} / 255", duration.as_secs(), pct), Measurement::SimulationProgress(source, duration, pct) => debug!("{source:?} simulation time: {} {} / 255", duration.as_secs(), pct),
Measurement::Annotation => () Measurement::Annotation => ()
} }
let _ = recording_sink.try_publish(next_measurement); if recording_sink.try_publish(next_measurement).is_err() {
warn!("Could not publish measurement to recording bus. Is the recording bus stalled?");
}
} }
} }