mirror of
https://github.com/dragonpilot/dragonpilot.git
synced 2026-02-27 02:33:52 +08:00
332f568a82
Updated Python code with Python 3.6+ features:
- utf-8 encoding is now the default (PEP 3120)
- Replace list comprehensions by Generator Expressions (PEP 289)
- Replace yield loop by yield from (PEP 380)
- Remove the (object) subclass when defining a class
- Replace the IOError alias by OSError (PEP 3151)
- Define sets with curly braces {} instead of set()
- Remove "r" parameter from open function, which is default
Co-Authored-By: Adeeb Shihadeh <8762862+adeebshihadeh@users.noreply.github.com>
Co-Authored-By: GregorKikelj <96022003+GregorKikelj@users.noreply.github.com>
Co-authored-by: Adeeb Shihadeh <8762862+adeebshihadeh@users.noreply.github.com>
Co-authored-by: GregorKikelj <96022003+GregorKikelj@users.noreply.github.com>
32 lines
1.1 KiB
Python
Executable File
32 lines
1.1 KiB
Python
Executable File
#!/usr/bin/env python3
|
|
|
|
import argparse
|
|
|
|
from selfdrive.test.process_replay.compare_logs import save_log
|
|
from selfdrive.test.process_replay.process_replay import CONFIGS, replay_process
|
|
from tools.lib.logreader import MultiLogIterator
|
|
from tools.lib.route import Route
|
|
|
|
if __name__ == "__main__":
|
|
parser = argparse.ArgumentParser(description="Run process on route and create new logs",
|
|
formatter_class=argparse.ArgumentDefaultsHelpFormatter)
|
|
parser.add_argument("route", help="The route name to use")
|
|
parser.add_argument("process", help="The process to run")
|
|
args = parser.parse_args()
|
|
|
|
cfg = [c for c in CONFIGS if c.proc_name == args.process][0]
|
|
|
|
route = Route(args.route)
|
|
lr = MultiLogIterator(route.log_paths(), wraparound=False)
|
|
inputs = list(lr)
|
|
|
|
outputs = replay_process(cfg, inputs)
|
|
|
|
# Remove message generated by the process under test and merge in the new messages
|
|
produces = {o.which() for o in outputs}
|
|
inputs = [i for i in inputs if i.which() not in produces]
|
|
outputs = sorted(inputs + outputs, key=lambda x: x.logMonoTime)
|
|
|
|
fn = f"{args.route}_{args.process}.bz2"
|
|
save_log(fn, outputs)
|