diff --git a/longterm_baseline.py b/longterm_baseline.py new file mode 100644 index 0000000000000000000000000000000000000000..05e59c7a7460e094f727dd34a477d506b489d93b --- /dev/null +++ b/longterm_baseline.py @@ -0,0 +1,10 @@ +import torch +import torch.nn as nn +import torch.nn.functional as F +import torch.optim as optim + + + + + + diff --git a/torchsample.tgz b/torchsample.tgz new file mode 100644 index 0000000000000000000000000000000000000000..4fd63c3cfea7eab1919b57b4392cefaef98277af Binary files /dev/null and b/torchsample.tgz differ diff --git a/toy.dataset.csv.gz b/toy.dataset.csv.gz new file mode 100644 index 0000000000000000000000000000000000000000..d0ce4605907c2ba97060d6b25179cc3e0a467a96 Binary files /dev/null and b/toy.dataset.csv.gz differ diff --git a/wait_for_ping_message.py b/wait_for_ping_message.py index d391a6de0eba84b04b5d2fee4d4c889ca4c0af65..3e466f9fb830facb5f9e246f1de39665ec475475 100755 --- a/wait_for_ping_message.py +++ b/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()):