Merge pull request #192 from cjtitus/fix_qt_dispatcher

Fixed bug in QtRemoteDispatcher
bluesky · Feb 2, 2024 · 362778f · 362778f
2 parents c409368 + e864534
commit 362778f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/bluesky_widgets/qt/kafka_dispatcher.py b/bluesky_widgets/qt/kafka_dispatcher.py
@@ -92,7 +92,7 @@ def continue_polling_forever():
         while continue_polling():
             try:
                 # there should maybe be a poll method on the dispatcher
-                msg = self._dispatcher._bluesky_consumer.consumer.poll(
+                msg = self._dispatcher._bluesky_consumer._consumer.poll(
                     self._dispatcher._bluesky_consumer.polling_duration
                 )
                 if msg is None:
@@ -116,7 +116,7 @@ def continue_polling_forever():
                                 # doc.
                                 logger.debug("keep waiting for a start document")
                                 return
-                        yield self._dispatcher._bluesky_consumer.consumer, msg.topic(), name, document
+                        yield self._dispatcher._bluesky_consumer._consumer, msg.topic(), name, document
                     except Exception as exc:
                         logger.exception(exc)
             except Exception as exc: