Skip to content

Commit

Permalink
Identing fix
Browse files Browse the repository at this point in the history
Signed-off-by: Flavia Beo <[email protected]>
  • Loading branch information
flaviabeo committed Aug 12, 2024
1 parent ad6604d commit c525364
Showing 1 changed file with 25 additions and 25 deletions.
50 changes: 25 additions & 25 deletions fmaas-router/src/rpc/info.rs
Original file line number Diff line number Diff line change
Expand Up @@ -47,30 +47,30 @@ impl InfoServicer {

#[tonic::async_trait]
impl InfoService for InfoServicer {
#[instrument(skip_all)]
async fn get_models_info(
&self,
request: Request<ModelInfoRequest>,
) -> Result<Response<ModelInfoResponse>, Status> {
let model_id = extract_model_id(&request)?;
let mir: &ModelInfoRequest = request.get_ref();
if mir.model_ids.is_empty() {
return Ok(Response::new(ModelInfoResponse::default()));
#[instrument(skip_all)]
async fn get_models_info(
&self,
request: Request<ModelInfoRequest>,
) -> Result<Response<ModelInfoResponse>, Status> {
let model_id = extract_model_id(&request)?;
let mir: &ModelInfoRequest = request.get_ref();
if mir.model_ids.is_empty() {
return Ok(Response::new(ModelInfoResponse::default()));
}
debug!(
"Routing get models info request for Model ID {}",
model_id
);
self.client(model_id)
.await?
.get_models_info(request)
.await
}
#[instrument(skip_all)]
async fn get_runtime_info(
&self,
_request: Request<RuntimeInfoRequest>,
) -> Result<Response<RuntimeInfoResponse>, Status> {
Err(Status::unimplemented("not implemented"))
}
debug!(
"Routing get models info request for Model ID {}",
model_id
);
self.client(model_id)
.await?
.get_models_info(request)
.await
}
#[instrument(skip_all)]
async fn get_runtime_info(
&self,
_request: Request<RuntimeInfoRequest>,
) -> Result<Response<RuntimeInfoResponse>, Status> {
Err(Status::unimplemented("not implemented"))
}
}

0 comments on commit c525364

Please sign in to comment.