diff --git a/selfdrive/test/process_replay/test_processes.py b/selfdrive/test/process_replay/test_processes.py
index afab6cc765..afa3dc5829 100755
--- a/selfdrive/test/process_replay/test_processes.py
+++ b/selfdrive/test/process_replay/test_processes.py
@@ -49,6 +49,7 @@ segments = [
   ("MAZDA", "fakedata|2022-01-20--18-09-32--0"),
 ]
 
+
 # dashcamOnly makes don't need to be tested until a full port is done
 excluded_interfaces = ["mock", "ford", "mazda", "tesla"]
 
@@ -180,9 +181,14 @@ if __name__ == "__main__":
 
   with concurrent.futures.ProcessPoolExecutor(max_workers=args.jobs) as pool:
     if not args.upload_only:
+      download_segments = segments.copy()
+      for car_brand, segment in segments:
+        if (len(args.whitelist_cars) and car_brand.upper() not in args.whitelist_cars) or \
+            (not len(args.whitelist_cars) and car_brand.upper() in args.blacklist_cars):
+          download_segments.remove((car_brand, segment))
       lreaders: Any = {}
-      p1 = pool.map(get_logreader, [seg for car, seg in segments])
-      for (segment, lr) in tqdm(p1, desc="Getting Logs", total=len(segments)):
+      p1 = pool.map(get_logreader, [seg for car, seg in download_segments])
+      for (segment, lr) in tqdm(p1, desc="Getting Logs", total=len(download_segments)):
         lreaders[segment] = lr
 
     pool_args: Any = []