nova_rerun_bridge.motion_storage

 1import json
 2import os
 3
 4PROCESSED_MOTIONS_FILE = "processed_motions.json"
 5
 6
 7def load_processed_motions():
 8    if os.path.exists(PROCESSED_MOTIONS_FILE):
 9        with open(PROCESSED_MOTIONS_FILE) as file:
10            return set(tuple(item) for item in json.load(file))
11    return set()
12
13
14def save_processed_motion(motion_id, trajectory_time):
15    processed_motions = load_processed_motions()
16    processed_motions.add((motion_id, trajectory_time))
17    with open(PROCESSED_MOTIONS_FILE, "w") as file:
18        json.dump(list(processed_motions), file)
PROCESSED_MOTIONS_FILE = 'processed_motions.json'
def load_processed_motions():
 8def load_processed_motions():
 9    if os.path.exists(PROCESSED_MOTIONS_FILE):
10        with open(PROCESSED_MOTIONS_FILE) as file:
11            return set(tuple(item) for item in json.load(file))
12    return set()
def save_processed_motion(motion_id, trajectory_time):
15def save_processed_motion(motion_id, trajectory_time):
16    processed_motions = load_processed_motions()
17    processed_motions.add((motion_id, trajectory_time))
18    with open(PROCESSED_MOTIONS_FILE, "w") as file:
19        json.dump(list(processed_motions), file)