fix ci ?

binaries/coordinator/src/lib.rs

@@ -422,34 +422,21 @@ async fn start_inner(
                             name,
                             grace_duration,
                         } => match resolve_name(name, &running_dataflows, &archived_dataflows) {
-                            Ok(dataflow_uuid) => {
-                                if let Some(result) = dataflow_results.get(&dataflow_uuid) {
-                                    let reply = ControlRequestReply::DataflowStopped {
-                                        uuid: dataflow_uuid,
-                                        result: dataflow_result(result, dataflow_uuid, &clock),
-                                    };
-                                    let _ = reply_sender.send(Ok(reply));
-
-                                    return Ok(());
-                                }
-
-                                let dataflow = stop_dataflow(
+                            Ok(uuid) => {
+                                stop_dataflow_by_uuid(
                                     &mut running_dataflows,
-                                    dataflow_uuid,
+                                    &dataflow_results,
+                                    uuid,
                                     &mut daemon_connections,
+                                    reply_sender,
                                     clock.new_timestamp(),
                                     grace_duration,
+                                    &clock,
                                 )
-                                .await;
-
-                                match dataflow {
-                                    Ok(dataflow) => {
-                                        dataflow.reply_senders.push(reply_sender);
-                                    }
-                                    Err(err) => {
-                                        let _ = reply_sender.send(Err(err));
-                                    }
-                                }
+                                .await?
+                            }
+                            Err(err) => {
+                                let _ = reply_sender.send(Err(err));
                             }
                             Err(err) => {
                                 let _ = reply_sender.send(Err(err));