CodeSource
/
Readur
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat(server): rename queue-failed endpoint

This commit is contained in:
perf3ct 2025-07-11 21:28:23 +00:00
parent f18696d4f8
commit e23d620a38
No known key found for this signature in database
GPG Key ID: 569C4EEC436F5232
6 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
docs/api-reference.md
View File

@ -475,7 +475,7 @@ Response:
#### Requeue Failed Items #### Requeue Failed Items
```bash ```bash
POST /api/queue/requeue-failed POST /api/queue/requeue/failed
Authorization: Bearer <jwt_token> Authorization: Bearer <jwt_token>
``` ```

2
docs/dev/QUEUE_IMPROVEMENTS.md
View File

@ -82,7 +82,7 @@ Returns:
### Requeue Failed Jobs ### Requeue Failed Jobs
``` ```
POST /api/queue/requeue-failed POST /api/queue/requeue/failed
``` ```
Requeues all failed jobs that haven't exceeded max attempts. Requeues all failed jobs that haven't exceeded max attempts.

2
frontend/src/services/api.ts
View File

@ -410,7 +410,7 @@ export const queueService = {
}, },
requeueFailed: () => { requeueFailed: () => {
return api.post('/queue/requeue-failed') return api.post('/queue/requeue/failed')
}, },
getOcrStatus: () => { getOcrStatus: () => {

2
src/routes/queue.rs
View File

@ -66,7 +66,7 @@ async fn get_queue_stats(
#[utoipa::path( #[utoipa::path(
post, post,
path = "/api/queue/requeue-failed", path = "/api/queue/requeue/failed",
tag = "queue", tag = "queue",
security( security(
("bearer_auth" = []) ("bearer_auth" = [])

4
tests/integration_ocr_queue_management_tests.rs
View File

@ -142,7 +142,7 @@ impl OCRQueueTestClient {
let token = self.token.as_ref().ok_or("Not authenticated")?; let token = self.token.as_ref().ok_or("Not authenticated")?;
let response = self.client let response = self.client
.post(&format!("{}/api/queue/requeue-failed", get_base_url())) .post(&format!("{}/api/queue/requeue/failed", get_base_url()))
.header("Authorization", format!("Bearer {}", token)) .header("Authorization", format!("Bearer {}", token))
.send() .send()
.await?; .await?;
@ -615,7 +615,7 @@ async fn test_queue_error_handling() {
// Test unauthorized requeue attempt // Test unauthorized requeue attempt
let unauth_requeue_response = unauth_client let unauth_requeue_response = unauth_client
.post(&format!("{}/api/queue/requeue-failed", get_base_url())) .post(&format!("{}/api/queue/requeue/failed", get_base_url()))
.send() .send()
.await .await
.expect("Request should complete"); .expect("Request should complete");

2
tests/integration_role_based_access_control_tests.rs
View File

@ -343,7 +343,7 @@ impl RBACTestClient {
} }
AdminOperation::RequeueFailedJobs => { AdminOperation::RequeueFailedJobs => {
self.client self.client
.post(&format!("{}/api/queue/requeue-failed", get_base_url())) .post(&format!("{}/api/queue/requeue/failed", get_base_url()))
.header("Authorization", format!("Bearer {}", token)) .header("Authorization", format!("Bearer {}", token))
.send() .send()
.await? .await?