initial commit: agentic office
Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
This commit is contained in:
@@ -46,9 +46,10 @@ pub async fn select_model(ollama_url: &str, client: &Client) -> Result<String, S
|
||||
return Err("Mallin nimi ei voi olla tyhjä".to_string());
|
||||
}
|
||||
|
||||
println!(" Ladataan malleja taustalla... Tämä voi kestää hetken ({})", new_model);
|
||||
// Odotetaan että pull on valmis
|
||||
let pull_body = serde_json::json!({ "name": &new_model });
|
||||
println!(" Ladataan mallia {}... (Tämä voi kestää isojen mallien kohdalla pitkään, älä sulje ohjelmaa.)", new_model);
|
||||
|
||||
// Odotetaan että pull on valmis, estetään stream jolloin yhteys pysyy auki latauksen loppuun
|
||||
let pull_body = serde_json::json!({ "name": &new_model, "stream": false });
|
||||
let resp = client.post(&format!("{}/api/pull", ollama_url))
|
||||
.json(&pull_body)
|
||||
.send()
|
||||
@@ -56,6 +57,8 @@ pub async fn select_model(ollama_url: &str, client: &Client) -> Result<String, S
|
||||
.map_err(|e| format!("Pull req virhe: {}", e))?;
|
||||
|
||||
if resp.status().is_success() {
|
||||
// Varmistetaan, että vastaus luetaan kokonaan loppuun ennen kuin jatketaan
|
||||
let _ = resp.text().await.map_err(|e| format!("Vastauksen lukuvirhe: {}", e))?;
|
||||
println!(" ✓ Malli {} ladattu onnistuneesti!", new_model);
|
||||
return Ok(new_model);
|
||||
} else {
|
||||
|
||||
Reference in New Issue
Block a user