♻️ Refactor: cleanup data_process_app.py

Author: jiangpeiling

backend/apps/data_process_app.py

@@ -162,30 +162,6 @@ async def load_image(url: str):
             status_code=HTTPStatus.INTERNAL_SERVER_ERROR, detail=f"Error loading image: {str(e)}")
 
 
-@router.get("/{task_id}")
-async def get_task(task_id: str):
-    """Get basic status information for a specific task"""
-    task = await get_task_info(task_id)
-
-    if not task:
-        raise HTTPException(
-            status_code=HTTPStatus.NOT_FOUND, detail=f"Task with ID {task_id} not found")
-    return JSONResponse(
-        status_code=HTTPStatus.OK,
-        content={
-            "id": task["id"],
-            "task_name": task["task_name"],
-            "index_name": task["index_name"],
-            "path_or_url": task["path_or_url"],
-            "original_filename": task["original_filename"],
-            "status": task["status"],
-            "created_at": task["created_at"],
-            "updated_at": task["updated_at"],
-            "error": task["error"]
-        }
-    )
-
-
 @router.get("")
 async def list_tasks():
     """Get a list of all tasks with their basic status information"""
@@ -291,7 +267,7 @@ async def process_text_file(
         )
         return JSONResponse(content=result)
     except Exception as e:
-        logger.error(
+        logger.exception(
             f"Error processing uploaded file {file.filename}: {str(e)}")
         raise HTTPException(
             status_code=HTTPStatus.INTERNAL_SERVER_ERROR,

test/backend/app/test_data_process_app.py

@@ -196,17 +196,6 @@ async def load_image():
             image = self.service.load_image.return_value
             return {"success": True, "base64": "mock_base64_data", "content_type": "image/jpeg"}
 
-        @self.app.get("/tasks/{task_id}")
-        @pytest.mark.asyncio
-        async def get_task(task_id: str):
-            # Simulate getting task information
-            task = self.get_task_info.return_value
-
-            if not task:
-                raise HTTPException(status_code=404, detail=f"Task with ID {task_id} not found")
-
-            return task
-
         @self.app.get("/tasks")
         @pytest.mark.asyncio
         async def list_tasks():
@@ -503,49 +492,6 @@ def test_load_image_failure(self):
         self.assertEqual(response.status_code, 404)
         self.assertIn("Failed to load image", response.json()["detail"])
 
-    def test_get_task_success(self):
-        """
-        Test getting task information successfully.
-        Verifies that the endpoint returns the expected task data.
-        """
-        # Set up mock
-        task_data = {
-            "id": self.task_id,
-            "task_name": "process_and_forward",
-            "index_name": self.index_name,
-            "path_or_url": self.source,
-            "status": "SUCCESS",
-            "created_at": "2023-01-01T12:00:00",
-            "updated_at": "2023-01-01T12:05:00",
-            "error": None
-        }
-        self.get_task_info.return_value = task_data
-
-        # Execute request
-        response = self.client.get(f"/tasks/{self.task_id}")
-
-        # Assert expectations
-        self.assertEqual(response.status_code, 200)
-        result = response.json()
-        self.assertEqual(result["id"], self.task_id)
-        self.assertEqual(result["status"], "SUCCESS")
-        self.assertEqual(result["index_name"], self.index_name)
-
-    def test_get_task_not_found(self):
-        """
-        Test getting non-existent task.
-        Verifies that the endpoint returns an appropriate error response.
-        """
-        # Set up mock to return None (task not found)
-        self.get_task_info.return_value = None
-
-        # Execute request
-        response = self.client.get("/tasks/nonexistent-id")
-
-        # Assert expectations
-        self.assertEqual(response.status_code, 404)
-        self.assertIn("not found", response.json()["detail"])
-
     def test_list_tasks(self):
         """
         Test listing all tasks.