diff --git a/apis/c++/node/src/lib.rs b/apis/c++/node/src/lib.rs index 77fd3197..61220ecf 100644 --- a/apis/c++/node/src/lib.rs +++ b/apis/c++/node/src/lib.rs @@ -82,7 +82,12 @@ fn event_type(event: &DoraEvent) -> ffi::DoraEventType { } fn event_as_input(event: Box) -> eyre::Result { - let Some(Event::Input { id, metadata: _, data }) = event.0 else { + let Some(Event::Input { + id, + metadata: _, + data, + }) = event.0 + else { bail!("not an input event"); }; let data: Option<&BinaryArray> = data.as_binary_opt(); diff --git a/binaries/coordinator/src/lib.rs b/binaries/coordinator/src/lib.rs index 72492c70..febb7b0f 100644 --- a/binaries/coordinator/src/lib.rs +++ b/binaries/coordinator/src/lib.rs @@ -251,8 +251,11 @@ async fn start_inner( // notify all machines that run parts of the dataflow for machine_id in &dataflow.machines { - let Some(connection) = daemon_connections.get_mut(machine_id) else { - tracing::warn!("no daemon connection found for machine `{machine_id}`"); + let Some(connection) = daemon_connections.get_mut(machine_id) + else { + tracing::warn!( + "no daemon connection found for machine `{machine_id}`" + ); continue; }; tcp_send(&mut connection.stream, &message) diff --git a/binaries/daemon/src/node_communication/mod.rs b/binaries/daemon/src/node_communication/mod.rs index 5af17d18..8fd200de 100644 --- a/binaries/daemon/src/node_communication/mod.rs +++ b/binaries/daemon/src/node_communication/mod.rs @@ -299,7 +299,11 @@ impl Listener { // iterate over queued events, newest first for event in self.queue.iter_mut().rev() { - let Some(Timestamped { inner: NodeEvent::Input { id, data, .. }, ..}) = event.as_mut() else { + let Some(Timestamped { + inner: NodeEvent::Input { id, data, .. }, + .. + }) = event.as_mut() + else { continue; }; match queue_size_remaining.get_mut(id) { diff --git a/binaries/runtime/src/lib.rs b/binaries/runtime/src/lib.rs index e903581b..9d903889 100644 --- a/binaries/runtime/src/lib.rs +++ b/binaries/runtime/src/lib.rs @@ -190,7 +190,9 @@ async fn run( } let Some(config) = operators.get(&operator_id) else { - tracing::warn!("received Finished event for unknown operator `{operator_id}`"); + tracing::warn!( + "received Finished event for unknown operator `{operator_id}`" + ); continue; }; let outputs = config diff --git a/binaries/runtime/src/operator/python.rs b/binaries/runtime/src/operator/python.rs index cc555aa5..5b2b12df 100644 --- a/binaries/runtime/src/operator/python.rs +++ b/binaries/runtime/src/operator/python.rs @@ -123,7 +123,9 @@ pub fn run( let mut reload = false; let reason = loop { #[allow(unused_mut)] - let Ok(mut event) = incoming_events.recv() else { break StopReason::InputsClosed }; + let Ok(mut event) = incoming_events.recv() else { + break StopReason::InputsClosed; + }; if let Event::Reload { .. } = event { reload = true; diff --git a/binaries/runtime/src/operator/shared_lib.rs b/binaries/runtime/src/operator/shared_lib.rs index ca758c4f..6a91102c 100644 --- a/binaries/runtime/src/operator/shared_lib.rs +++ b/binaries/runtime/src/operator/shared_lib.rs @@ -168,7 +168,7 @@ impl<'lib> SharedLibraryOperator<'lib> { let reason = loop { #[allow(unused_mut)] let Ok(mut event) = self.incoming_events.recv() else { - break StopReason::InputsClosed + break StopReason::InputsClosed; }; let span = span!(tracing::Level::TRACE, "on_event", input_id = field::Empty); diff --git a/libraries/extensions/ros2-bridge/python/src/lib.rs b/libraries/extensions/ros2-bridge/python/src/lib.rs index 8b3abb11..37ac68a6 100644 --- a/libraries/extensions/ros2-bridge/python/src/lib.rs +++ b/libraries/extensions/ros2-bridge/python/src/lib.rs @@ -238,7 +238,7 @@ impl Ros2Subscription { .take_seed(self.deserializer.clone()) .context("failed to take next message from subscription")?; let Some((value, _info)) = message else { - return Ok(None) + return Ok(None); }; let message = value.to_pyarrow(py)?;