Function run_zero_config_worker

cake-mobile/src/lib.rs:329–459

(
    name: &str,
    cluster_key: &str,
    address: &str,
    cache_dir: &std::path::Path,
    _model: &str,
)

// ---------------------------------------------------------------------------

async fn run_zero_config_worker(
    name: &str,
    cluster_key: &str,
    address: &str,
    cache_dir: &std::path::Path,
    _model: &str,
) -> String {
    let progress_cb = |stage: &str, message: &str, progress: f64| {
        update_status(stage, message, progress);
    };

    let (layers, model_path, listener) = match cake::sharding::worker_setup_with_progress(
        name,
        cluster_key,
        address,
        cache_dir,
        Some(&progress_cb),
    )
    .await
    {
        Ok(result) => result,
        Err(e) => {
            update_status("error", &format!("Setup failed: {}", e), 0.0);
            return format!("worker setup failed: {}", e);
        }
    };

    log_mobile(&format!("[cake-mobile] master assigned layers: {:?}", layers));
    log_mobile(&format!("[cake-mobile] model path: {}", model_path.display()));

    let mut topology = Topology::new();
    topology.insert(
        name.to_string(),
        cake::Node {
            host: address.to_string(),
            description: None,
            layers: layers.clone(),
            vram_bytes: 0,
            tflops: 0.0,
            backend: String::new(),
            hostname: String::new(),
            os: String::new(),
        },
    );

    let force_cpu = should_force_cpu();
    if force_cpu {
        log_mobile("[cake-mobile] GPU not supported on this device, using CPU backend");
    }

    let args = Args {
        address: address.to_string(),
        mode: Mode::Worker,
        name: Some(name.to_string()),
        model: model_path.to_string_lossy().to_string(),
        model_type: ModelType::TextModel,
        topology_override: Some(topology),
        cpu: force_cpu,