diff --git a/apps/admin-api/src/app.rs b/apps/admin-api/src/app.rs index 2d9b159..f297e41 100644 --- a/apps/admin-api/src/app.rs +++ b/apps/admin-api/src/app.rs @@ -1857,7 +1857,10 @@ mod tests { .unwrap(); let response = client - .get(format!("{base_url}/stream-sessions/{}", session_id.as_str())) + .get(format!( + "{base_url}/stream-sessions/{}", + session_id.as_str() + )) .send() .await .unwrap(); diff --git a/apps/admin-api/src/service.rs b/apps/admin-api/src/service.rs index 09df05f..22c5414 100644 --- a/apps/admin-api/src/service.rs +++ b/apps/admin-api/src/service.rs @@ -1671,7 +1671,8 @@ impl AdminService { let job = if matches!(job.status, JobStatus::Completed) { job } else { - self.touch_async_job_poll_if_ready(workspace_id, job).await? + self.touch_async_job_poll_if_ready(workspace_id, job) + .await? }; Ok(async_job_detail_view(job)) @@ -1718,7 +1719,9 @@ impl AdminService { ) })?; ensure_async_job_workspace(&job, workspace_id)?; - let job = self.touch_async_job_poll_if_ready(workspace_id, job).await?; + let job = self + .touch_async_job_poll_if_ready(workspace_id, job) + .await?; match job.status { JobStatus::Completed => Ok(job.result.unwrap_or(Value::Null)),