|
1 | 1 | import logging |
2 | 2 | from typing import Annotated, Any |
3 | 3 |
|
4 | | -from celery_library.errors import TaskNotFoundError |
5 | 4 | from common_library.error_codes import create_error_code |
6 | 5 | from fastapi import APIRouter, Depends, FastAPI, HTTPException, status |
7 | 6 | from models_library.api_schemas_long_running_tasks.base import TaskProgress |
@@ -110,16 +109,10 @@ async def get_task_status( |
110 | 109 | ): |
111 | 110 | task_manager = get_task_manager(app) |
112 | 111 |
|
113 | | - try: |
114 | | - task_status = await task_manager.get_task_status( |
115 | | - task_filter=_get_task_filter(user_id, product_name), |
116 | | - task_uuid=TaskUUID(f"{task_id}"), |
117 | | - ) |
118 | | - except TaskNotFoundError as err: |
119 | | - raise HTTPException( |
120 | | - status_code=status.HTTP_404_NOT_FOUND, |
121 | | - detail="Task not found", |
122 | | - ) from err |
| 112 | + task_status = await task_manager.get_task_status( |
| 113 | + task_filter=_get_task_filter(user_id, product_name), |
| 114 | + task_uuid=TaskUUID(f"{task_id}"), |
| 115 | + ) |
123 | 116 |
|
124 | 117 | return TaskStatus( |
125 | 118 | task_progress=TaskProgress( |
@@ -184,16 +177,10 @@ async def get_task_result( |
184 | 177 | task_manager = get_task_manager(app) |
185 | 178 | task_filter = _get_task_filter(user_id, product_name) |
186 | 179 |
|
187 | | - try: |
188 | | - task_status = await task_manager.get_task_status( |
189 | | - task_filter=task_filter, |
190 | | - task_uuid=TaskUUID(f"{task_id}"), |
191 | | - ) |
192 | | - except TaskNotFoundError as err: |
193 | | - raise HTTPException( |
194 | | - status_code=status.HTTP_404_NOT_FOUND, |
195 | | - detail="Task not found", |
196 | | - ) from err |
| 180 | + task_status = await task_manager.get_task_status( |
| 181 | + task_filter=task_filter, |
| 182 | + task_uuid=TaskUUID(f"{task_id}"), |
| 183 | + ) |
197 | 184 |
|
198 | 185 | if not task_status.is_done: |
199 | 186 | raise HTTPException( |
|
0 commit comments