updated name of _dispatcher._bluesky_consumer._consumer, which was ou…

…tdated and causing QtRemoteDispatcher to crash
bluesky · Jan 30, 2024 · e864534 · e864534
1 parent c409368
commit e864534
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: