diff --git a/litellm/proxy/auth/auth_checks.py b/litellm/proxy/auth/auth_checks.py
index 49bce0855e..10037e60fd 100644
--- a/litellm/proxy/auth/auth_checks.py
+++ b/litellm/proxy/auth/auth_checks.py
@@ -18,46 +18,16 @@ from litellm.proxy._types import (
     LitellmUserRoles,
 )
 from typing import Optional, Literal, Union
-from litellm.proxy.utils import PrismaClient, ProxyLogging
+from litellm.proxy.utils import PrismaClient, ProxyLogging, log_to_opentelemetry
 from litellm.caching import DualCache
 import litellm
 from opentelemetry.trace import Span
-from functools import wraps
 from litellm.types.services import ServiceLoggerPayload, ServiceTypes
 from datetime import datetime
 
 all_routes = LiteLLMRoutes.openai_routes.value + LiteLLMRoutes.management_routes.value
 
 
-def log_to_opentelemetry(func):
-    @wraps(func)
-    async def wrapper(*args, **kwargs):
-        start_time = datetime.now()
-        result = await func(*args, **kwargs)
-        end_time = datetime.now()
-
-        # Log to OTEL only if "parent_otel_span" is in kwargs and is not None
-        if (
-            "parent_otel_span" in kwargs
-            and kwargs["parent_otel_span"] is not None
-            and "proxy_logging_obj" in kwargs
-            and kwargs["proxy_logging_obj"] is not None
-        ):
-            proxy_logging_obj = kwargs["proxy_logging_obj"]
-            await proxy_logging_obj.service_logging_obj.async_service_success_hook(
-                service=ServiceTypes.DB,
-                call_type=func.__name__,
-                parent_otel_span=kwargs["parent_otel_span"],
-                duration=0.0,
-                start_time=start_time,
-                end_time=end_time,
-            )
-        # end of logging to otel
-        return result
-
-    return wrapper
-
-
 def common_checks(
     request_body: dict,
     team_object: Optional[LiteLLM_TeamTable],
diff --git a/litellm/proxy/utils.py b/litellm/proxy/utils.py
index 549b0f2abc..e5efb93d05 100644
--- a/litellm/proxy/utils.py
+++ b/litellm/proxy/utils.py
@@ -47,6 +47,8 @@ from email.mime.multipart import MIMEMultipart
 from datetime import datetime, timedelta
 from litellm.integrations.slack_alerting import SlackAlerting
 from typing_extensions import overload
+from opentelemetry.trace import Span
+from functools import wraps
 
 
 def print_verbose(print_statement):
@@ -62,6 +64,35 @@ def print_verbose(print_statement):
         print(f"LiteLLM Proxy: {print_statement}")  # noqa
 
 
+def log_to_opentelemetry(func):
+    @wraps(func)
+    async def wrapper(*args, **kwargs):
+        start_time = datetime.now()
+        result = await func(*args, **kwargs)
+        end_time = datetime.now()
+
+        # Log to OTEL only if "parent_otel_span" is in kwargs and is not None
+        if (
+            "parent_otel_span" in kwargs
+            and kwargs["parent_otel_span"] is not None
+            and "proxy_logging_obj" in kwargs
+            and kwargs["proxy_logging_obj"] is not None
+        ):
+            proxy_logging_obj = kwargs["proxy_logging_obj"]
+            await proxy_logging_obj.service_logging_obj.async_service_success_hook(
+                service=ServiceTypes.DB,
+                call_type=func.__name__,
+                parent_otel_span=kwargs["parent_otel_span"],
+                duration=0.0,
+                start_time=start_time,
+                end_time=end_time,
+            )
+        # end of logging to otel
+        return result
+
+    return wrapper
+
+
 ### LOGGING ###
 class ProxyLogging:
     """
@@ -831,6 +862,7 @@ class PrismaClient:
         max_time=10,  # maximum total time to retry for
         on_backoff=on_backoff,  # specifying the function to call on backoff
     )
+    @log_to_opentelemetry
     async def get_data(
         self,
         token: Optional[Union[str, list]] = None,
@@ -857,6 +889,8 @@ class PrismaClient:
         limit: Optional[
             int
         ] = None,  # pagination, number of rows to getch when find_all==True
+        parent_otel_span: Optional[Span] = None,
+        proxy_logging_obj: Optional[ProxyLogging] = None,
     ):
         args_passed_in = locals()
         start_time = time.time()