readd profile spans

Author: bisgaard-itis

services/catalog/src/simcore_service_catalog/api/rpc/_services.py

@@ -26,6 +26,7 @@
     CatalogForbiddenError,
     CatalogItemNotFoundError,
 )
+from servicelib.tracing import with_profiled_span
 
 from ...models.services_db import ServiceDBFilters
 from ...repository.groups import GroupsRepository
@@ -61,6 +62,7 @@ async def _wrapper(app: FastAPI, **kwargs):
 
 @router.expose(reraise_if_error_type=(CatalogForbiddenError, ValidationError))
 @_profile_rpc_call
+@with_profiled_span
 @validate_call(config={"arbitrary_types_allowed": True})
 async def list_services_paginated(
     app: FastAPI,

services/director-v2/src/simcore_service_director_v2/api/rpc/_computations.py

@@ -16,6 +16,7 @@
 from models_library.services_types import ServiceRunID
 from models_library.users import UserID
 from servicelib.rabbitmq import RPCRouter
+from servicelib.tracing import with_profiled_span
 from servicelib.utils import limited_gather
 
 from ...core.errors import ComputationalRunNotFoundError
@@ -35,6 +36,7 @@
 
 
 @router.expose(reraise_if_error_type=())
+@with_profiled_span
 async def list_computations_latest_iteration_page(
     app: FastAPI,
     *,

services/web/server/src/simcore_service_webserver/users/_notifications_rest.py

@@ -12,6 +12,7 @@
     parse_request_path_parameters_as,
 )
 from servicelib.redis import handle_redis_returns_union_types
+from servicelib.tracing import with_profiled_span
 
 from .._meta import API_VTAG
 from ..login.decorators import login_required
@@ -124,6 +125,7 @@ async def mark_notification_as_read(request: web.Request) -> web.Response:
 @routes.get(f"/{API_VTAG}/me/permissions", name="list_user_permissions")
 @login_required
 @permission_required("user.permissions.read")
+@with_profiled_span
 async def list_user_permissions(request: web.Request) -> web.Response:
     req_ctx = UsersRequestContext.model_validate(request)
     list_permissions: list[UserPermission] = await _users_service.list_user_permissions(

services/web/server/src/simcore_service_webserver/users/_users_rest.py

@@ -26,6 +26,7 @@
 )
 from servicelib.logging_utils import log_context
 from servicelib.rest_constants import RESPONSE_MODEL_POLICY
+from servicelib.tracing import with_profiled_span
 
 from .._meta import API_VTAG
 from ..exception_handling import (
@@ -112,6 +113,7 @@
 @routes.get(f"/{API_VTAG}/me", name="get_my_profile")
 @login_required
 @_handle_users_exceptions
+@with_profiled_span
 async def get_my_profile(request: web.Request) -> web.Response:
     product: Product = products_web.get_current_product(request)
     req_ctx = UsersRequestContext.model_validate(request)