diff --git a/binaries/coordinator/src/run/mod.rs b/binaries/coordinator/src/run/mod.rs index 963761a7a..a2e06a792 100644 --- a/binaries/coordinator/src/run/mod.rs +++ b/binaries/coordinator/src/run/mod.rs @@ -49,8 +49,8 @@ pub(super) async fn spawn_dataflow( dataflow_id: uuid, working_dir, nodes: nodes.clone(), - machine_listen_ports: machine_listen_ports.clone(), - dataflow_descriptor: dataflow.clone(), + machine_listen_ports, + dataflow_descriptor: dataflow, }; let message = serde_json::to_vec(&Timestamped { inner: DaemonCoordinatorEvent::Spawn(spawn_command),