linse/frappy_sinq
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

change sea_recorder argument to dict

Browse Source 
+ send sea_recorder to sea only when needed
This commit is contained in:
zolliker
2025-06-18 09:57:18 +02:00
parent c217b1c264
commit 806490322e
1 changed files with 8 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
devices.py
View File

@ -349,23 +349,22 @@ class FrappyConfig(Device):
fm = FrappyManager() fm = FrappyManager()
ins = config.instrument ins = config.instrument
fm.get_server_state(ins, new_cfg) fm.get_server_state(ins, new_cfg)
recorders = [] recorders = {}
for service, secnode in secnodes.items(): for service, secnode in secnodes.items():
recorder = '0'
if services.get(service) and secnode: if services.get(service) and secnode:
cfg = fm.frappy_cfgs.get(service) cfg = fm.frappy_cfgs.get(service)
seacfg = fm.frappy2sea.get(cfg) seacfg = fm.frappy2sea.get(cfg)
if secnode() and not seacfg: if secnode() and not seacfg:
if cfg: if cfg:
recorder = f'localhost:{fm.info[ins].get(service, 0)}/{cfg}' recorders[service] = f'localhost:{fm.info[ins].get(service, 0)}/{cfg}'
else: else:
recorder = secnode.uri recorders[service] = secnode.uri
secnode._secnode.connect() secnode._secnode.connect()
recorders.append(recorder) if recorders:
try: try:
fm.sea.sea_recorder(ins, recorders) fm.sea.sea_recorder(ins, recorders)
except Exception: except Exception:
pass pass
self.set_envalias() self.set_envalias()
for secnode in remove_cfg: for secnode in remove_cfg:
secnode.disable() secnode.disable()