From df81f4e48a7b0683310a5bf8231fefe9f850d88a Mon Sep 17 00:00:00 2001 From: Philipp Wolfer Date: Tue, 15 Aug 2023 14:25:34 +0200 Subject: [PATCH] Make pipe tests more robust on error --- test/test_util_pipe.py | 23 ++++++++++++----------- 1 file changed, 12 insertions(+), 11 deletions(-) diff --git a/test/test_util_pipe.py b/test/test_util_pipe.py index 81e6e9fb9..6941b08a5 100644 --- a/test/test_util_pipe.py +++ b/test/test_util_pipe.py @@ -62,18 +62,19 @@ class TestPipe(PicardTestCase): for message in to_send: __pool = concurrent.futures.ThreadPoolExecutor() pipe_handler = pipe.Pipe(self.NAME, self.VERSION) - plistener = __pool.submit(pipe_listener, pipe_handler) - res = "" - - # handle the write/read processes try: - pipe_handler.send_to_pipe(message) - res = plistener.result(timeout=6) - except concurrent.futures._base.TimeoutError: - pass + plistener = __pool.submit(pipe_listener, pipe_handler) + res = "" + + # handle the write/read processes + try: + pipe_handler.send_to_pipe(message) + res = plistener.result(timeout=6) + except concurrent.futures._base.TimeoutError: + pass + + self.assertEqual(res, message, + "Data is sent and read correctly") finally: pipe_handler.stop() __pool.shutdown() - - self.assertEqual(res, message, - "Data is sent and read correctly")