This reverts commit 8c7da1dbd0.
8c7da1dbd0
@ -21,7 +21,6 @@ SEND_EXTRA_INPUTS = bool(int(os.getenv("SEND_EXTRA_INPUTS", "0")))
def get_log_fn(ref_commit, test_route):
# TODO: regenerate with zst
return f"{test_route}_model_tici_{ref_commit}.bz2"
@ -15,7 +15,6 @@ TESTED_SEGMENTS = [
def ci_setup_data_readers(route, sidx):
# TODO: use openpilotci source!
lr = LogReader(get_url(route, sidx, "rlog"))
frs = {
'roadCameraState': FrameReader(get_url(route, sidx, "fcamera")),
@ -54,7 +54,6 @@ class AzureContainer:
return client, key
def get_url(self, route_name: str, segment_num, log_type="rlog") -> str:
# TODO: this is too rigid
ext = "hevc" if log_type.endswith('camera') else "bz2"
return self.BASE_URL + f"{route_name.replace('|', '/')}/{segment_num}/{log_type}.{ext}"
@ -87,5 +87,4 @@ def get_repo_url(path):
def get_url(route, segment, file="rlog.bz2"):
# TODO: future segments can be .zst
return get_repo_url(f"segments/{route.replace('|', '/')}/{segment}/{file}")
@ -164,7 +164,6 @@ def internal_source_zst(sr: SegmentRange, mode: ReadMode, file_ext: str = "zst")
def openpilotci_source(sr: SegmentRange, mode: ReadMode) -> LogPaths:
# TODO: fixup these sources to support any log file extension
rlog_paths = [get_url(sr.route_name, seg, "rlog") for seg in sr.seg_idxs]
qlog_paths = [get_url(sr.route_name, seg, "qlog") for seg in sr.seg_idxs]