fix async job path op

Author: giancarloromeo

api/specs/web-server/_long_running_tasks.py

@@ -31,15 +31,15 @@
     "/tasks",
     response_model=Envelope[list[TaskGet]],
 )
-def list_tasks():
+def get_async_jobs():
     """Lists all long running tasks"""
 
 
 @router.get(
     "/tasks/{task_id}",
     response_model=Envelope[TaskStatus],
 )
-def get_task_status(
+def get_async_job_status(
     _path_params: Annotated[_PathParam, Depends()],
 ):
     """Retrieves the status of a task"""
@@ -48,7 +48,7 @@ def get_task_status(
 @router.get(
     "/tasks/{task_id}/stream",
 )
-def get_task_stream(
+def get_async_job_stream(
     _path_params: Annotated[_PathParam, Depends()],
 ):
     """Retrieves the stream of a task"""
@@ -58,7 +58,7 @@ def get_task_stream(
     "/tasks/{task_id}",
     status_code=status.HTTP_204_NO_CONTENT,
 )
-def cancel_task(
+def cancel_async_job(
     _path_params: Annotated[_PathParam, Depends()],
 ):
     """Cancels and removes a task"""
@@ -68,7 +68,7 @@ def cancel_task(
     "/tasks/{task_id}/result",
     response_model=Any,
 )
-def get_task_result(
+def get_async_job_result(
     _path_params: Annotated[_PathParam, Depends()],
 ):
     """Retrieves the result of a task"""

api/specs/web-server/_long_running_tasks_legacy.py

@@ -23,40 +23,40 @@
 @router.get(
     "",
     response_model=Envelope[list[TaskGet]],
-    name="list_tasks_legacy",
-    description="Lists all long running tasks (legacy)",
+    name="list_tasks",
+    description="Lists all long running tasks",
 )
-async def list_tasks_legacy(): ...
+async def list_tasks(): ...
 
 
 @router.get(
     "/{task_id}",
     response_model=Envelope[TaskStatus],
-    name="get_task_status_legacy",
-    description="Retrieves the status of a task (legacy)",
+    name="get_task_status",
+    description="Retrieves the status of a task",
 )
-async def get_task_status_legacy(
+async def get_task_status(
     _path_params: Annotated[_PathParam, Depends()],
 ): ...
 
 
 @router.delete(
     "/{task_id}",
-    name="remove_task_legacy",
-    description="Cancels and removes a task (legacy)",
+    name="remove_task",
+    description="Cancels and removes a task",
     status_code=status.HTTP_204_NO_CONTENT,
 )
-async def remove_task_legacy(
+async def remove_task(
     _path_params: Annotated[_PathParam, Depends()],
 ): ...
 
 
 @router.get(
     "/{task_id}/result",
-    name="get_task_result_legacy",
+    name="get_task_result",
     response_model=Any,
-    description="Retrieves the result of a task (legacy)",
+    description="Retrieves the result of a task",
 )
-async def get_task_result_legacy(
+async def get_task_result(
     _path_params: Annotated[_PathParam, Depends()],
 ): ...

services/web/server/src/simcore_service_webserver/api/v0/openapi.yaml

@@ -3882,9 +3882,9 @@ paths:
     get:
       tags:
       - long-running-tasks
-      summary: List Tasks
+      summary: Get Async Jobs
       description: Lists all long running tasks
-      operationId: list_tasks
+      operationId: get_async_jobs
       responses:
         '200':
           description: Successful Response
@@ -3920,9 +3920,9 @@ paths:
     get:
       tags:
       - long-running-tasks
-      summary: Get Task Status
+      summary: Get Async Job Status
       description: Retrieves the status of a task
-      operationId: get_task_status
+      operationId: get_async_job_status
       parameters:
       - name: task_id
         in: path
@@ -3964,9 +3964,9 @@ paths:
     delete:
       tags:
       - long-running-tasks
-      summary: Cancel Task
+      summary: Cancel Async Job
       description: Cancels and removes a task
-      operationId: cancel_task
+      operationId: cancel_async_job
       parameters:
       - name: task_id
         in: path
@@ -4005,9 +4005,9 @@ paths:
     get:
       tags:
       - long-running-tasks
-      summary: Get Task Stream
+      summary: Get Async Job Stream
       description: Retrieves the stream of a task
-      operationId: get_task_stream
+      operationId: get_async_job_stream
       parameters:
       - name: task_id
         in: path
@@ -4049,9 +4049,9 @@ paths:
     get:
       tags:
       - long-running-tasks
-      summary: Get Task Result
+      summary: Get Async Job Result
       description: Retrieves the result of a task
-      operationId: get_task_result
+      operationId: get_async_job_result
       parameters:
       - name: task_id
         in: path
@@ -4065,7 +4065,7 @@ paths:
           content:
             application/json:
               schema:
-                title: Response Get Task Result
+                title: Response Get Async Job Result
         '404':
           content:
             application/json:
@@ -4094,9 +4094,9 @@ paths:
     get:
       tags:
       - long-running-tasks-legacy
-      summary: List Tasks Legacy
-      description: Lists all long running tasks (legacy)
-      operationId: list_tasks_legacy
+      summary: List Tasks
+      description: Lists all long running tasks
+      operationId: list_tasks
       responses:
         '200':
           description: Successful Response
@@ -4108,9 +4108,9 @@ paths:
     get:
       tags:
       - long-running-tasks-legacy
-      summary: Get Task Status Legacy
-      description: Retrieves the status of a task (legacy)
-      operationId: get_task_status_legacy
+      summary: Get Task Status
+      description: Retrieves the status of a task
+      operationId: get_task_status
       parameters:
       - name: task_id
         in: path
@@ -4128,9 +4128,9 @@ paths:
     delete:
       tags:
       - long-running-tasks-legacy
-      summary: Remove Task Legacy
-      description: Cancels and removes a task (legacy)
-      operationId: remove_task_legacy
+      summary: Remove Task
+      description: Cancels and removes a task
+      operationId: remove_task
       parameters:
       - name: task_id
         in: path
@@ -4145,9 +4145,9 @@ paths:
     get:
       tags:
       - long-running-tasks-legacy
-      summary: Get Task Result Legacy
-      description: Retrieves the result of a task (legacy)
-      operationId: get_task_result_legacy
+      summary: Get Task Result
+      description: Retrieves the result of a task
+      operationId: get_task_result
       parameters:
       - name: task_id
         in: path
@@ -4161,7 +4161,7 @@ paths:
           content:
             application/json:
               schema:
-                title: Response Get Task Result Legacy
+                title: Response Get Task Result
   /v0/catalog/licensed-items:
     get:
       tags:

services/web/server/src/simcore_service_webserver/tasks/_controller/_rest.py

@@ -38,12 +38,12 @@
 
 @routes.get(
     _task_prefix,
-    name="get_tasks",
+    name="get_async_jobs",
 )
 @login_required
 @handle_rest_requests_exceptions
 @webserver_request_context_decorator
-async def get_tasks(request: web.Request) -> web.Response:
+async def get_async_jobs(request: web.Request) -> web.Response:
     inprocess_long_running_manager = get_long_running_manager(request.app)
     inprocess_tracked_tasks = await lrt_api.list_tasks(
         inprocess_long_running_manager.rpc_client,
@@ -89,11 +89,11 @@ async def get_tasks(request: web.Request) -> web.Response:
 
 @routes.get(
     _task_prefix + "/{task_id}",
-    name="get_task_status",
+    name="get_async_job_status",
 )
 @login_required
 @handle_rest_requests_exceptions
-async def get_task_status(request: web.Request) -> web.Response:
+async def get_async_job_status(request: web.Request) -> web.Response:
 
     _req_ctx = AuthenticatedRequestContext.model_validate(request)
     _path_params = parse_request_path_parameters_as(TaskPathParams, request)
@@ -124,11 +124,11 @@ async def get_task_status(request: web.Request) -> web.Response:
 
 @routes.delete(
     _task_prefix + "/{task_id}",
-    name="cancel_task",
+    name="cancel_async_job",
 )
 @login_required
 @handle_rest_requests_exceptions
-async def cancel_task(request: web.Request) -> web.Response:
+async def cancel_async_job(request: web.Request) -> web.Response:
 
     _req_ctx = AuthenticatedRequestContext.model_validate(request)
     _path_params = parse_request_path_parameters_as(TaskPathParams, request)
@@ -149,11 +149,11 @@ async def cancel_task(request: web.Request) -> web.Response:
 
 @routes.get(
     _task_prefix + "/{task_id}/result",
-    name="get_task_result",
+    name="get_async_job_result",
 )
 @login_required
 @handle_rest_requests_exceptions
-async def get_task_result(request: web.Request) -> web.Response:
+async def get_async_job_result(request: web.Request) -> web.Response:
 
     _req_ctx = AuthenticatedRequestContext.model_validate(request)
     _path_params = parse_request_path_parameters_as(TaskPathParams, request)