diff lib/patchablegraph.py @ 429:fcd2c026f51e

exportStats for sending scales data to influxdb Ignore-this: 715ff40fed97559efa37edf0efa58220
author drewp@bigasterisk.com
date Sun, 07 Apr 2019 03:56:17 -0700
parents a380561fd8a8
children 388769b5f8ff
line wrap: on
line diff
--- a/lib/patchablegraph.py	Thu Apr 04 02:22:04 2019 -0700
+++ b/lib/patchablegraph.py	Sun Apr 07 03:56:17 2019 -0700
@@ -138,13 +138,13 @@
     def bind(self):
         graphJson = self.masterGraph.asJsonLd()
         log.debug("send fullGraph event: %s", graphJson)
-        self.sendEvent(message=graphJson, event='fullGraph')
+        self.sendEvent(message=graphJson, event=b'fullGraph')
         self.masterGraph.addObserver(self.onPatch)
 
     def onPatch(self, patchJson):
         # throttle and combine patches here- ideally we could see how
         # long the latency to the client is to make a better rate choice
-        self.sendEvent(message=patchJson, event='patch')
+        self.sendEvent(message=patchJson, event=b'patch')
                
     def unbind(self):
         self.masterGraph.removeObserver(self.onPatch)