We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7acf245 commit 5ed2ca0Copy full SHA for 5ed2ca0
bluesky_queueserver/manager/output_streaming.py
@@ -232,12 +232,12 @@ def _publishing_thread(self):
232
break
233
234
def _publish(self, payload):
235
- if self._console_output_on and payload["channel"] == "console":
+ channel = payload["channel"]
236
+ if self._console_output_on and channel == "console":
237
sys.__stdout__.write(payload["msg"])
238
sys.__stdout__.flush()
239
240
if self._zmq_publish_on and self._socket:
- channel = payload["channel"]
241
if channel == "console":
242
topic = self._zmq_topic_console
243
elif channel == "info":
0 commit comments