cleanup

crypto-org-chain · May 27, 2024 · 8105b1d · 8105b1d
1 parent 25e0c77
commit 8105b1d
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/testground/benchmark/benchmark/main.py b/testground/benchmark/benchmark/main.py
@@ -1,4 +1,3 @@
-import json
 import os
 import queue
 

diff --git a/testground/benchmark/benchmark/sync.py b/testground/benchmark/benchmark/sync.py
@@ -87,7 +87,7 @@ def _subscribe(self, topic, callback):
         "send one request, recv multiple responses"
 
         def on_recv(msg):
-            callback(msg["subscribe"] if msg is not None else None)
+            callback(json.loads(msg["subscribe"]) if msg is not None else None)
 
         id = self.next_id()
         self._handlers[id] = on_recv