kalugin66/windmill
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix breaking error (#7162)

Browse Source
This commit is contained in:
centdix
2025-11-17 21:51:29 +01:00
committed by GitHub
parent dbac8fbba7
commit 2a0bd52876
1 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
backend/windmill-api/src/ai.rs
View File

@@ -509,10 +509,7 @@ async fn proxy(
}
// Transform Bedrock responses back to OpenAI format
if matches!(provider, AIProvider::AWSBedrock) {
let Some(model) = model else {
return Err(Error::BadRequest("Model is required".to_string()));
};
if matches!(provider, AIProvider::AWSBedrock) && model.is_some() {
if is_streaming {
// Transform streaming response
use http::StatusCode;
@@ -523,7 +520,8 @@ async fn proxy(
response_headers.insert("connection", "keep-alive".parse().unwrap());
let stream = response.bytes_stream();
let transformed_stream = bedrock::transform_bedrock_stream_to_openai(stream, model);
let transformed_stream =
bedrock::transform_bedrock_stream_to_openai(stream, model.unwrap());
Ok((
StatusCode::OK,
@@ -532,7 +530,8 @@ async fn proxy(
))
} else {
// Transform non-streaming response
let transformed_body = bedrock::transform_bedrock_to_openai(response, model).await?;
let transformed_body =
bedrock::transform_bedrock_to_openai(response, model.unwrap()).await?;
let mut response_headers = HeaderMap::new();
response_headers.insert("content-type", "application/json".parse().unwrap());