bec/debye_bec
0
0
Fork 0
Code Issues 9 Pull Requests 2 Actions Packages Projects Releases Wiki Activity

fix(nidaq_writer): fixed redis connector after refactoring

Browse Source
This commit is contained in:
wakonig_k
2024-03-05 22:51:09 +01:00
parent b2fb77d93b
commit ab4a4bdb76
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
bec_plugins/services/NIDAQ_writer/NIDAQ_writer.py
View File

@@ -58,7 +58,7 @@ class NIDAQWriterService(BECService):
"""
Callback for scan status messages.
"""
msg = messages.ScanStatusMessage.loads(message.value)
msg = message.value
if not msg:
return
parent.handle_scan_status(msg)
@@ -99,7 +99,7 @@ class NIDAQWriterService(BECService):
start_time = time.time()
if self.use_redis_stream:
msg = self.producer.xread("ni_data")
msg = self.connector.xread("ni_data")
if msg:
try:
@@ -118,7 +118,7 @@ class NIDAQWriterService(BECService):
logger.error(f"Failed to parse message: {content}")
time.sleep(0.01)
else:
msgs = self.producer.r.lpop("ni_data:val", 20)
msgs = self.connector._redis_conn.lpop("ni_data:val", 20)
time.sleep(0.001)
if msgs:
try: