From e864534f8254b40e42e357304af083e5ed2268a9 Mon Sep 17 00:00:00 2001 From: Charles Titus Date: Tue, 30 Jan 2024 11:49:22 -0500 Subject: [PATCH] updated name of _dispatcher._bluesky_consumer._consumer, which was outdated and causing QtRemoteDispatcher to crash --- bluesky_widgets/qt/kafka_dispatcher.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/bluesky_widgets/qt/kafka_dispatcher.py b/bluesky_widgets/qt/kafka_dispatcher.py index 6a480b96..679f24a7 100644 --- 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: