Mercurial > code > home > repos > light9
changeset 2288:ce1c73235ee2
minor
| author | drewp@bigasterisk.com |
|---|---|
| date | Mon, 29 May 2023 22:32:50 -0700 |
| parents | 62b832e9aac5 |
| children | f2c6b39c155c |
| files | light9/collector/collector_client_asyncio.py light9/collector/service.py light9/effect/sequencer/service.py |
| diffstat | 3 files changed, 3 insertions(+), 3 deletions(-) [+] |
line wrap: on
line diff
--- a/light9/collector/collector_client_asyncio.py Mon May 29 21:31:41 2023 -0700 +++ b/light9/collector/collector_client_asyncio.py Mon May 29 22:32:50 2023 -0700 @@ -32,7 +32,7 @@ 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])
--- a/light9/collector/service.py Mon May 29 21:31:41 2023 -0700 +++ b/light9/collector/service.py Mon May 29 22:32:50 2023 -0700 @@ -84,6 +84,7 @@ [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:
--- a/light9/effect/sequencer/service.py Mon May 29 21:31:41 2023 -0700 +++ b/light9/effect/sequencer/service.py Mon May 29 22:32:50 2023 -0700 @@ -19,7 +19,6 @@ 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 @@ 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,