feat(server): rename queue-failed endpoint
This commit is contained in:
parent
b31e1a672d
commit
e16fd1d420
|
|
@ -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>
|
||||||
```
|
```
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -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.
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -410,7 +410,7 @@ export const queueService = {
|
||||||
},
|
},
|
||||||
|
|
||||||
requeueFailed: () => {
|
requeueFailed: () => {
|
||||||
return api.post('/queue/requeue-failed')
|
return api.post('/queue/requeue/failed')
|
||||||
},
|
},
|
||||||
|
|
||||||
getOcrStatus: () => {
|
getOcrStatus: () => {
|
||||||
|
|
|
||||||
|
|
@ -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" = [])
|
||||||
|
|
|
||||||
|
|
@ -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");
|
||||||
|
|
|
||||||
|
|
@ -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?
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue