From 8a3b2303a2ec89fc1e7cbaf8beba86d34b11f9ad Mon Sep 17 00:00:00 2001 From: Victoria Fischer Date: Fri, 27 Mar 2026 22:39:42 +0100 Subject: [PATCH] tasks: motion: give warning if recording bus is stalled --- src/tasks/motion.rs | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/tasks/motion.rs b/src/tasks/motion.rs index c75415f..e100746 100644 --- a/src/tasks/motion.rs +++ b/src/tasks/motion.rs @@ -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::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?"); + } } } \ No newline at end of file