()
| 77 | |
| 78 | |
| 79 | def get_trajectory_tracker(): |
| 80 | hdfs_dir = os.getenv('VERL_TRACKER_HDFS_DIR', default=None) |
| 81 | verbose = os.getenv('VERL_TRACKER_VERBOSE', default='0') == '1' |
| 82 | assert hdfs_dir is not None |
| 83 | tracker = TrajectoryTracker.options(name="global_tracker", get_if_exists=True, |
| 84 | lifetime="detached").remote(hdfs_dir, verbose) |
| 85 | return tracker |
| 86 | |
| 87 | |
| 88 | if __name__ == '__main__': |
no outgoing calls
no test coverage detected