Skip to content

Commit 03872ac

Browse files
committed
clippy fixes for cicd
1 parent ed5fd02 commit 03872ac

3 files changed

Lines changed: 19 additions & 19 deletions

File tree

api/src/routes/experiments.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,7 @@ pub async fn add_run(
9191
.bind(&req.metrics)
9292
.fetch_one(&state.db)
9393
.await?;
94-
notify(&state.db, claims.sub, "Experiment Run Logged", &format!("New run added to experiment"), NotifyType::Info, Some(&format!("/experiments/{}", experiment_id))).await;
94+
notify(&state.db, claims.sub, "Experiment Run Logged", "New run added to experiment", NotifyType::Info, Some(&format!("/experiments/{}", experiment_id))).await;
9595
Ok(Json(run))
9696
}
9797

api/src/routes/inference.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@ pub async fn run(
7373
.fetch_one(&state.db)
7474
.await?;
7575

76-
notify(&state.db, claims.sub, "Inference Started", &format!("Inference job started for model"), NotifyType::Info, Some(&format!("/inference/{}", job_id))).await;
76+
notify(&state.db, claims.sub, "Inference Started", "Inference job started for model", NotifyType::Info, Some(&format!("/inference/{}", job_id))).await;
7777
Ok(Json(job))
7878
}
7979

api/src/routes/sdk.rs

Lines changed: 17 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -62,23 +62,21 @@ pub async fn register_model(
6262
.fetch_optional(&state.db)
6363
.await?
6464
}
65+
} else if let Some(pid) = project_id {
66+
sqlx::query_as(
67+
"SELECT * FROM models WHERE name = $1 AND project_id = $2 ORDER BY version DESC LIMIT 1"
68+
)
69+
.bind(&req.name)
70+
.bind(pid)
71+
.fetch_optional(&state.db)
72+
.await?
6573
} else {
66-
if let Some(pid) = project_id {
67-
sqlx::query_as(
68-
"SELECT * FROM models WHERE name = $1 AND project_id = $2 ORDER BY version DESC LIMIT 1"
69-
)
70-
.bind(&req.name)
71-
.bind(pid)
72-
.fetch_optional(&state.db)
73-
.await?
74-
} else {
75-
sqlx::query_as(
76-
"SELECT * FROM models WHERE name = $1 AND project_id IS NULL ORDER BY version DESC LIMIT 1"
77-
)
78-
.bind(&req.name)
79-
.fetch_optional(&state.db)
80-
.await?
81-
}
74+
sqlx::query_as(
75+
"SELECT * FROM models WHERE name = $1 AND project_id IS NULL ORDER BY version DESC LIMIT 1"
76+
)
77+
.bind(&req.name)
78+
.fetch_optional(&state.db)
79+
.await?
8280
};
8381

8482
let from_registry = req.registry_name.is_some();
@@ -133,8 +131,10 @@ pub async fn register_model(
133131
.bind(workspace_id)
134132
.bind(if from_registry {
135133
if new_version == 1 { "Installed from registry" } else { "Updated from registry" }
134+
} else if new_version == 1 {
135+
"Initial version from workspace"
136136
} else {
137-
if new_version == 1 { "Initial version from workspace" } else { "Updated from workspace" }
137+
"Updated from workspace"
138138
})
139139
.execute(&state.db)
140140
.await?;

0 commit comments

Comments
 (0)