style: removed unused imports

hydro_deploy/core/src/kubernetes/launched_binary.rs

@@ -3,8 +3,7 @@ use std::sync::Arc;
 
 use async_channel::{Receiver, Sender};
 use async_trait::async_trait;
-use futures::io::BufReader;
-use futures::{AsyncBufReadExt, StreamExt, TryStreamExt};
+use futures::{StreamExt, TryStreamExt};
 use kube::api::AttachedProcess;
 use tokio::sync::RwLock;
 

hydro_deploy/core/src/kubernetes/mod.rs

@@ -7,22 +7,18 @@ use anyhow::Result;
 use async_trait::async_trait;
 use hydroflow_cli_integration::ServerBindConfig;
 use tokio::sync::RwLock;
-use std::fs::Metadata;
 
 use super::{
     ClientStrategy, Host, HostTargetType, LaunchedBinary, LaunchedHost, ResourceBatch,
     ResourceResult, ServerStrategy,
 };
 
 use futures::{StreamExt, TryStreamExt};
-use std::io::Write;
 use k8s_openapi::api::core::v1::Pod;
 use kube::{
     api::{Api, AttachParams, ListParams, PostParams, ResourceExt, WatchEvent, WatchParams},
     Client,
 };
-use std::time::Duration;
-use tokio::time::sleep;
 
 use tokio::io::AsyncWriteExt;
 use nanoid::nanoid;

hydro_deploy/core/src/ssh.rs

@@ -11,7 +11,7 @@ use async_ssh2_lite::ssh2::ErrorCode;
 use async_ssh2_lite::{AsyncChannel, AsyncSession, Error, SessionConfiguration};
 use async_trait::async_trait;
 use futures::io::BufReader;
-use futures::{AsyncBufReadExt, AsyncWriteExt, StreamExt, TryStreamExt, join};
+use futures::{AsyncBufReadExt, AsyncWriteExt, StreamExt};
 use hydroflow_cli_integration::ServerBindConfig;
 use nanoid::nanoid;
 use tokio::net::{TcpListener, TcpStream};

hydroflow/src/util/cli.rs

@@ -2,11 +2,6 @@
 
 use std::cell::RefCell;
 use std::collections::HashMap;
-use std::io::Write;
-use std::fs::File;
-use std::fs::OpenOptions;
-use std::net::{IpAddr, Ipv4Addr, SocketAddr};
-
 
 pub use hydroflow_cli_integration::*;
 use serde::de::DeserializeOwned;
@@ -62,10 +57,9 @@ impl<T> HydroCLI<T> {
 async fn init_no_ack_start<T: DeserializeOwned + Default>() -> HydroCLI<T> {
     let mut input = String::new();
     std::io::stdin().read_line(&mut input).unwrap();
-    let mut trimmed = input.trim();
+    let trimmed = input.trim();
 
     let bind_config = serde_json::from_str::<InitConfig>(trimmed).unwrap();
-    // println!("{:?}", bind_config);
 
     // config telling other services how to connect to me
     let mut bind_results: HashMap<String, ServerPort> = HashMap::new();