From a3cc68356e2ff60606f18eba1c61202568de2f95 Mon Sep 17 00:00:00 2001 From: Tom Willemsen Date: Wed, 10 Jun 2026 14:29:51 +0100 Subject: [PATCH] Emit stop before start when making new run --- src/howl.rs | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/src/howl.rs b/src/howl.rs index 69bebe6..3d6ad62 100644 --- a/src/howl.rs +++ b/src/howl.rs @@ -175,29 +175,29 @@ fn produce_messages( match producer.send( BaseRecord::to(conf.run_info_topic) .key("") - .payload(generate_run_start( - fbb, - conf.event_message_config.det_max, - conf.event_topic, - current_job_id, - )) + .payload(generate_run_stop(fbb, current_job_id)) .timestamp(now_nanos / 1_000_000), ) { Ok(_) => {} Err(err) => { - error!("Failed to send run start: {}", err.0); + error!("Failed to send run stop: {}", err.0); } } *current_job_id = Uuid::new_v4().to_string(); match producer.send( BaseRecord::to(conf.run_info_topic) .key("") - .payload(generate_run_stop(fbb, current_job_id)) + .payload(generate_run_start( + fbb, + conf.event_message_config.det_max, + conf.event_topic, + current_job_id, + )) .timestamp(now_nanos / 1_000_000), ) { Ok(_) => {} Err(err) => { - error!("Failed to send run stop: {}", err.0); + error!("Failed to send run start: {}", err.0); } } }