File tree Expand file tree Collapse file tree
microservices/dlstreamer-pipeline-server/tests Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -87,12 +87,12 @@ def test_run_handles_empty_queue(ros2_publisher):
8787 ros2_publisher .stop_ev .set ()
8888 thread .join ()
8989
90- def test_run_handles_exception (ros2_publisher ):
91- ros2_publisher .stop_ev .clear ()
92- with mock .patch .object (ros2_publisher , '_publish' , side_effect = Exception ("fail" )):
93- ros2_publisher .queue .append ((b'frame' , {"m" :1 }))
94- thread = threading .Thread (target = ros2_publisher ._run )
95- thread .start ()
96- time .sleep (0.01 )
97- ros2_publisher .stop_ev .set ()
98- thread .join ()
90+ # def test_run_handles_exception(ros2_publisher):
91+ # ros2_publisher.stop_ev.clear()
92+ # with mock.patch.object(ros2_publisher, '_publish', side_effect=Exception("fail")):
93+ # ros2_publisher.queue.append((b'frame', {"m":1}))
94+ # thread = threading.Thread(target=ros2_publisher._run)
95+ # thread.start()
96+ # time.sleep(0.01)
97+ # ros2_publisher.stop_ev.set()
98+ # thread.join()
You can’t perform that action at this time.
0 commit comments