bsodfather/crank
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

style: format admin streaming poll throttling

Browse Source
This commit is contained in:
a.tolmachev
2026-05-02 10:55:12 +00:00
parent f1de3dc948
commit 73bebee8f6
2 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
apps/admin-api/src/app.rs
+4 -1
View File
@@ -1857,7 +1857,10 @@ mod tests {
.unwrap(); .unwrap();
let response = client let response = client
.get(format!("{base_url}/stream-sessions/{}", session_id.as_str())) .get(format!(
"{base_url}/stream-sessions/{}",
session_id.as_str()
))
.send() .send()
.await .await
.unwrap(); .unwrap();
apps/admin-api/src/service.rs
+5 -2
View File
@@ -1671,7 +1671,8 @@ impl AdminService {
let job = if matches!(job.status, JobStatus::Completed) { let job = if matches!(job.status, JobStatus::Completed) {
job job
} else { } 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)) Ok(async_job_detail_view(job))
@@ -1718,7 +1719,9 @@ impl AdminService {
) )
})?; })?;
ensure_async_job_workspace(&job, workspace_id)?; 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 { match job.status {
JobStatus::Completed => Ok(job.result.unwrap_or(Value::Null)), JobStatus::Completed => Ok(job.result.unwrap_or(Value::Null)),