# HG changeset patch # User drewp@bigasterisk.com # Date 2023-05-30 05:32:50 # Node ID ce1c73235ee21b053c02701f281208b952898abe # Parent 62b832e9aac578d768069ac744d536ec9cbcc25e minor diff --git a/light9/collector/collector_client_asyncio.py b/light9/collector/collector_client_asyncio.py --- a/light9/collector/collector_client_asyncio.py +++ b/light9/collector/collector_client_asyncio.py @@ -32,7 +32,7 @@ class _Sender: async def send(self, client: str, session: str, settings: DeviceSettings): msg = toCollectorJson(client, session, settings).encode('utf8') - # log.info(f'send {len(msg)}') + # log.info(f'zmq send {len(msg)}') await self.socket.send_multipart([b'setAttr', msg]) diff --git a/light9/collector/service.py b/light9/collector/service.py --- a/light9/collector/service.py +++ b/light9/collector/service.py @@ -84,6 +84,7 @@ async def zmqListener(collector): [topic, msg] = await sock.recv_multipart() if topic != b'setAttr': raise ValueError(topic) + # log.info(f'zmq recv {len(msg)}') client, clientSession, settings, sendTime = parseJsonMessage(collector.graph, msg) collector.setAttrs(client, clientSession, settings, sendTime) except: diff --git a/light9/effect/sequencer/service.py b/light9/effect/sequencer/service.py --- a/light9/effect/sequencer/service.py +++ b/light9/effect/sequencer/service.py @@ -19,7 +19,6 @@ from light9 import networking from light9.collector.collector_client_asyncio import sendToCollector from light9.effect.sequencer.eval_faders import FaderEval from light9.effect.sequencer.sequencer import Sequencer, StateUpdate -from light9.metrics import metrics from light9.run_local import log RATE = 20 @@ -62,7 +61,7 @@ def main(): ds = faders.computeOutput() await sendToCollector('effectSequencer', session='0', settings=ds) - faders_loop = loop_forever(update, metric_prefix='faders', sleep_period=1 / RATE) + faders_loop = loop_forever(func=update, metric_prefix='faders', sleep_period=1 / RATE) app = Starlette( debug=True,