diff lib/patchablegraph.py @ 1232:b50a13ef20ba

exportStats for sending scales data to influxdb Ignore-this: 715ff40fed97559efa37edf0efa58220 darcs-hash:bcdd9713c4bf9c2ebe732ae1d30edc44f1be704f
author drewp <drewp@bigasterisk.com>
date Sun, 07 Apr 2019 03:56:17 -0700
parents 3d478b05f9b1
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)