Fix or silence clippy warnings

binaries/cli/src/attach.rs

@@ -157,13 +157,13 @@ pub fn attach_dataflow(
             Ok(AttachEvent::Control(control_request)) => control_request,
             Ok(AttachEvent::Log(Ok(log_message))) => {
                 let LogMessage {
-                    dataflow_id,
+                    dataflow_id: _,
                     node_id,
                     level,
                     target,
-                    module_path,
-                    file,
-                    line,
+                    module_path: _,
+                    file: _,
+                    line: _,
                     message,
                 } = log_message;
                 let level = match level {

binaries/coordinator/src/lib.rs

@@ -601,6 +601,7 @@ async fn start_inner(
     Ok(())
 }
 
+#[allow(clippy::too_many_arguments)]
 async fn stop_dataflow_by_uuid(
     running_dataflows: &mut HashMap<Uuid, RunningDataflow>,
     dataflow_results: &HashMap<Uuid, BTreeMap<String, DataflowDaemonResult>>,

binaries/daemon/src/lib.rs

@@ -87,6 +87,8 @@ pub struct Daemon {
     clock: Arc<uhlc::HLC>,
 }
 
+type DaemonRunResult = BTreeMap<Uuid, BTreeMap<NodeId, Result<(), NodeError>>>;
+
 impl Daemon {
     pub async fn run(
         coordinator_addr: SocketAddr,
@@ -227,7 +229,7 @@ impl Daemon {
         machine_id: String,
         exit_when_done: Option<BTreeSet<(Uuid, NodeId)>>,
         clock: Arc<HLC>,
-    ) -> eyre::Result<BTreeMap<Uuid, BTreeMap<NodeId, Result<(), NodeError>>>> {
+    ) -> eyre::Result<DaemonRunResult> {
         let coordinator_connection = match coordinator_addr {
             Some(addr) => {
                 let stream = TcpStream::connect(addr)
@@ -272,7 +274,7 @@ impl Daemon {
     async fn run_inner(
         mut self,
         incoming_events: impl Stream<Item = Timestamped<Event>> + Unpin,
-    ) -> eyre::Result<BTreeMap<Uuid, BTreeMap<NodeId, Result<(), NodeError>>>> {
+    ) -> eyre::Result<DaemonRunResult> {
         let mut events = incoming_events;
 
         while let Some(event) = events.next().await {