)]}'
{"tripleoclient/heat_launcher.py":[{"author":{"_account_id":8833,"name":"Rabi Mishra","email":"ramishra@redhat.com","username":"rabi"},"change_message_id":"5a8ed3deb28aa5b6e36245bca71a4ff53608bfd1","unresolved":true,"context_lines":[{"line_number":637,"context_line":"           wait\u003dwait_fixed(0.5))"},{"line_number":638,"context_line":"    def wait_for_message_queue(self):"},{"line_number":639,"context_line":"        output \u003d subprocess.check_output(["},{"line_number":640,"context_line":"            \u0027sudo\u0027, \u0027podman\u0027, \u0027exec\u0027, \u0027-it\u0027, \u0027rabbitmq\u0027,"},{"line_number":641,"context_line":"            \u0027rabbitmqctl\u0027, \u0027list_queues\u0027"},{"line_number":642,"context_line":"        ])"},{"line_number":643,"context_line":"        if \u0027heat\u0027 not in str(output):"}],"source_content_type":"text/x-python","patch_set":1,"id":"c56bdf00_057c7468","line":640,"range":{"start_line":640,"start_character":38,"end_line":640,"end_character":43},"updated":"2021-05-18 14:02:09.000000000","message":"Not required to use interactive mode. I\u0027ve a patch to clean it on master.\n\n\nhttps://review.opendev.org/c/openstack/python-tripleoclient/+/791629","commit_id":"516b39d608381101ae390826c21d045c80881c49"},{"author":{"_account_id":7353,"name":"Kevin Carter","email":"kevin@cloudnull.com","username":"cloudnull"},"change_message_id":"92ae1beaec7d5f124fc6c8e81a2f4e567cec9a03","unresolved":true,"context_lines":[{"line_number":636,"context_line":"           stop\u003d(stop_after_delay(10) | stop_after_attempt(10)),"},{"line_number":637,"context_line":"           wait\u003dwait_fixed(0.5))"},{"line_number":638,"context_line":"    def wait_for_message_queue(self):"},{"line_number":639,"context_line":"        output \u003d subprocess.check_output(["},{"line_number":640,"context_line":"            \u0027sudo\u0027, \u0027podman\u0027, \u0027exec\u0027, \u0027-it\u0027, \u0027rabbitmq\u0027,"},{"line_number":641,"context_line":"            \u0027rabbitmqctl\u0027, \u0027list_queues\u0027"},{"line_number":642,"context_line":"        ])"},{"line_number":643,"context_line":"        if \u0027heat\u0027 not in str(output):"},{"line_number":644,"context_line":"            msg \u003d \"Message queue for ephemeral heat not created in time.\""},{"line_number":645,"context_line":"            raise HeatPodMessageQueueException(msg)"}],"source_content_type":"text/x-python","patch_set":1,"id":"3e357484_9c2c4405","line":642,"range":{"start_line":639,"start_character":0,"end_line":642,"end_character":10},"updated":"2021-05-18 13:36:40.000000000","message":"while I can see how this works, and agree this is probably ok, I wonder if we could use oslo or the python rabbitmq (kombu?) to connect to the cluster and actually inspect the queues instead of bashing our way to success?","commit_id":"516b39d608381101ae390826c21d045c80881c49"}]}