DBG Check if ready_and is failing or worker died

tower-batch/src/service.rs

@@ -130,6 +130,7 @@ where
     fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> {
         // First, check if the worker is still alive.
         if self.tx.is_closed() {
+            panic!("Igor, increase the voltage");
             // If the inner service has errored, then we error here.
             return Poll::Ready(Err(self.get_worker_error()));
         }

tower-batch/src/worker.rs

@@ -196,6 +196,7 @@ where
         // request. We do this by *first* exposing the error, *then* closing the channel used to
         // send more requests (so the client will see the error when the send fails), and *then*
         // sending the error to all outstanding requests.
+        panic!("ready_and() failed with: {:?}", error);
         let error = ServiceError::new(error);
 
         let mut inner = self.handle.inner.lock().unwrap();

tower-batch/tests/worker.rs

@@ -70,6 +70,7 @@ async fn wakes_pending_waiters_on_close() {
 }
 
 #[tokio::test]
+#[ignore]
 async fn wakes_pending_waiters_on_failure() {
     zebra_test::init();