(
worker_name: &str,
cluster_key: &str,
bind_address: &str,
model_cache_dir: &Path,
)
| 817 | pub type SetupProgressFn = dyn Fn(&str, &str, f64) + Send + Sync; |
| 818 | |
| 819 | pub async fn worker_setup( |
| 820 | worker_name: &str, |
| 821 | cluster_key: &str, |
| 822 | bind_address: &str, |
| 823 | model_cache_dir: &Path, |
| 824 | ) -> Result<(Vec<String>, PathBuf, TcpListener)> { |
| 825 | worker_setup_with_progress(worker_name, cluster_key, bind_address, model_cache_dir, None).await |
| 826 | } |
| 827 | |
| 828 | pub async fn worker_setup_with_progress( |
| 829 | worker_name: &str, |
no test coverage detected