Run `cargo fmt --all`

apis/c++/node/src/lib.rs

@@ -82,7 +82,12 @@ fn event_type(event: &DoraEvent) -> ffi::DoraEventType {
 }
 
 fn event_as_input(event: Box<DoraEvent>) -> eyre::Result<ffi::DoraInput> {
-    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();

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)

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) {

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

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;

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);

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)?;