verl/utils/debug/trajectory_tracker.py

• save_to_hdfs · function · L33-L46 — def save_to_hdfs(data: io.BytesIO, name, hdfs_dir, verbose)
• TrajectoryTracker · class · L50-L66 — class TrajectoryTracker()
• init · method · L52-L57 — def init(self, hdfs_dir, verbose) -> None
• dump · method · L59-L61 — def dump(self, data: io.BytesIO, name): # get a temp file and write to it
• wait_for_hdfs · method · L63-L66 — def wait_for_hdfs(self)
• dump_data · function · L69-L76 — def dump_data(data, name)
• get_trajectory_tracker · function · L79-L85 — def get_trajectory_tracker()
• process · function · L94-L96 — def process(iter)