From da07ff50b7cc9d945b029c7f676c9e3273163d3f Mon Sep 17 00:00:00 2001
From: Susa Giogoli <su.giogoli@icloud.com>
Date: Tue, 11 Jul 2023 12:23:25 +0200
Subject: [PATCH] fixed streams work too
---
writefile.py | 8 +++++---
1 file changed, 5 insertions(+), 3 deletions(-)
diff --git a/writefile.py b/writefile.py
index a8db790..67de44c 100644
--- a/writefile.py
+++ b/writefile.py
@@ -345,9 +345,11 @@ def triggerstreams(generatordict, streamslist, component, variablelist, jsonmeas
writeindent += " "
if stream["streamType"] == "fixed":
- server.write(writeindent + "time = count%" + str(stream["intervalValue"]) + "\n")
- server.write(writeindent + "if time == 0:\n")
- server.write(writeindent + "await " + generatorname + ".trigger()\n")
+ server.write(writeindent + stream["measurement"] + "time = count % " + str(stream["intervalValue"]) + "\n")
+ server.write(writeindent + "if "+ stream["measurement"] + "time == 0:\n")
+ writeindent += " "
+ server.write(writeindent + "puffer = await " + valuename + ".get_value()\n")
+ server.write(writeindent + "await " + generatorname + ".trigger(message=\"" + stream["measurement"] + " value: \" + str(puffer))\n")
writeindent = ""
for i in range(indent):
writeindent += " "
--
GitLab