playground

longterm_baseline.py

+import torch
+import torch.nn as nn
+import torch.nn.functional as F
+import torch.optim as optim
+
+
+
+
+
+

wait_for_ping_message.py

@@ -38,12 +38,11 @@ def dataset_maintain_thread_main():
     while True:
         message = ws.recv()
         # print("DEBUG: message=", message)
-        parsed = json.loads(message)
-        if 'a' in parsed.keys() and 'b' in parsed.keys():
+        if len(message) > 1000:
             # Is a depth snapshot update
             a = 1
         else:
-            print("ERROR: unexpected message (maybe ping message): ", message)
+            print("D: ", message)
 
         ###### DEBUG ONLY
         # if int(time.time()) % 60 == 0 and _debug_tmp != int(time.time()):