Propagete poll_ready to warp svc

quickwit-oss · Apr 3, 2024 · 436c347 · 436c347
1 parent df5c8bb
commit 436c347
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/quickwit/quickwit-lambda/src/searcher/warp_lambda.rs b/quickwit/quickwit-lambda/src/searcher/warp_lambda.rs
@@ -123,8 +123,10 @@ where
     type Error = LambdaError;
     type Future = Pin<Box<dyn Future<Output = Result<Self::Response, Self::Error>> + Send + 'a>>;
 
-    fn poll_ready(&mut self, _: &mut Context<'_>) -> Poll<Result<(), Self::Error>> {
-        core::task::Poll::Ready(Ok(()))
+    fn poll_ready(&mut self, ctx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> {
+        self.warp_service
+            .poll_ready(ctx)
+            .map_err(|err| match err {})
     }
 
     fn call(&mut self, req: Request) -> Self::Future {