fix: disable grpc when readonly (#3105)

src/phoenix/server/app.py

@@ -264,11 +264,13 @@ def _lifespan(
     tracer_provider: Optional["TracerProvider"] = None,
     enable_prometheus: bool = False,
     clean_ups: Iterable[Callable[[], None]] = (),
+    read_only: bool = False,
 ) -> StatefulLifespan[Starlette]:
     @contextlib.asynccontextmanager
     async def lifespan(_: Starlette) -> AsyncIterator[Dict[str, Any]]:
         async with bulk_inserter as (queue_span, queue_evaluation), GrpcServer(
             queue_span,
+            disabled=read_only,
             tracer_provider=tracer_provider,
             enable_prometheus=enable_prometheus,
         ):
@@ -394,6 +396,7 @@ def __init__(self, *args: Any, **kwargs: Any) -> None:
         prometheus_middlewares = []
     app = Starlette(
         lifespan=_lifespan(
+            read_only=read_only,
             bulk_inserter=bulk_inserter,
             tracer_provider=tracer_provider,
             enable_prometheus=enable_prometheus,

src/phoenix/server/grpc_server.py

@@ -51,13 +51,17 @@ def __init__(
         callback: Callable[[Span, ProjectName], Awaitable[None]],
         tracer_provider: Optional["TracerProvider"] = None,
         enable_prometheus: bool = False,
+        disabled: bool = False,
     ) -> None:
         self._callback = callback
         self._server: Optional[Server] = None
         self._tracer_provider = tracer_provider
         self._enable_prometheus = enable_prometheus
+        self._disabled = disabled
 
     async def __aenter__(self) -> None:
+        if self._disabled:
+            return
         interceptors: List[ServerInterceptor] = []
         if self._enable_prometheus:
             ...