rename module

Author: Andrei Neagu

packages/service-library/src/servicelib/aiohttp/long_running_tasks/_routes.py

@@ -5,7 +5,7 @@
 from servicelib.aiohttp import status
 from servicelib.aiohttp.rest_responses import create_data_response
 
-from ...long_running_tasks import endpoint_responses
+from ...long_running_tasks import http_endpoint_responses
 from ...long_running_tasks.models import TaskGet, TaskId, TaskStatus
 from ..requests_validation import parse_request_path_parameters_as
 from ._dependencies import get_task_context, get_tasks_manager
@@ -30,7 +30,7 @@ async def list_tasks(request: web.Request) -> web.Response:
                 result_href=f"{request.app.router['get_task_result'].url_for(task_id=t.task_id)}",
                 abort_href=f"{request.app.router['cancel_and_delete_task'].url_for(task_id=t.task_id)}",
             )
-            for t in endpoint_responses.list_tasks(tasks_manager, task_context)
+            for t in http_endpoint_responses.list_tasks(tasks_manager, task_context)
         ]
     )
 
@@ -41,7 +41,7 @@ async def get_task_status(request: web.Request) -> web.Response:
     tasks_manager = get_tasks_manager(request.app)
     task_context = get_task_context(request)
 
-    task_status: TaskStatus = endpoint_responses.get_task_status(
+    task_status: TaskStatus = http_endpoint_responses.get_task_status(
         tasks_manager, task_context, path_params.task_id
     )
     return create_data_response(task_status)
@@ -54,7 +54,7 @@ async def get_task_result(request: web.Request) -> web.Response | Any:
     task_context = get_task_context(request)
 
     # NOTE: this might raise an exception that will be catched by the _error_handlers
-    return await endpoint_responses.get_task_result(
+    return await http_endpoint_responses.get_task_result(
         tasks_manager, task_context, path_params.task_id
     )
 
@@ -64,7 +64,7 @@ async def cancel_and_delete_task(request: web.Request) -> web.Response:
     path_params = parse_request_path_parameters_as(_PathParam, request)
     tasks_manager = get_tasks_manager(request.app)
     task_context = get_task_context(request)
-    await endpoint_responses.remove_task(
+    await http_endpoint_responses.remove_task(
         tasks_manager, task_context, path_params.task_id
     )
     return web.json_response(status=status.HTTP_204_NO_CONTENT)

packages/service-library/src/servicelib/fastapi/long_running_tasks/_routes.py

@@ -2,7 +2,7 @@
 
 from fastapi import APIRouter, Depends, Request, status
 
-from ...long_running_tasks import endpoint_responses
+from ...long_running_tasks import http_endpoint_responses
 from ...long_running_tasks.models import TaskGet, TaskId, TaskResult, TaskStatus
 from ...long_running_tasks.task import TasksManager
 from ..requests_decorators import cancel_on_disconnect
@@ -27,7 +27,7 @@ async def list_tasks(
                 request.url_for("cancel_and_delete_task", task_id=t.task_id)
             ),
         )
-        for t in endpoint_responses.list_tasks(tasks_manager, task_context=None)
+        for t in http_endpoint_responses.list_tasks(tasks_manager, task_context=None)
     ]
 
 
@@ -45,7 +45,7 @@ async def get_task_status(
     tasks_manager: Annotated[TasksManager, Depends(get_tasks_manager)],
 ) -> TaskStatus:
     assert request  # nosec
-    return endpoint_responses.get_task_status(
+    return http_endpoint_responses.get_task_status(
         tasks_manager, task_context=None, task_id=task_id
     )
 
@@ -66,7 +66,7 @@ async def get_task_result(
     tasks_manager: Annotated[TasksManager, Depends(get_tasks_manager)],
 ) -> TaskResult | Any:
     assert request  # nosec
-    return await endpoint_responses.get_task_result(
+    return await http_endpoint_responses.get_task_result(
         tasks_manager, task_context=None, task_id=task_id
     )
 
@@ -87,6 +87,6 @@ async def cancel_and_delete_task(
     tasks_manager: Annotated[TasksManager, Depends(get_tasks_manager)],
 ) -> None:
     assert request  # nosec
-    await endpoint_responses.remove_task(
+    await http_endpoint_responses.remove_task(
         tasks_manager, task_context=None, task_id=task_id
     )