summaryrefslogtreecommitdiff
path: root/experiments/kp_innovation_short_development.py
diff options
context:
space:
mode:
Diffstat (limited to 'experiments/kp_innovation_short_development.py')
-rw-r--r--experiments/kp_innovation_short_development.py56
1 files changed, 56 insertions, 0 deletions
diff --git a/experiments/kp_innovation_short_development.py b/experiments/kp_innovation_short_development.py
new file mode 100644
index 0000000..a4c5645
--- /dev/null
+++ b/experiments/kp_innovation_short_development.py
@@ -0,0 +1,56 @@
+#!/usr/bin/env python3
+"""Run the three frozen MT-1 mixed-traffic development records."""
+import argparse
+import json
+import os
+import subprocess
+import sys
+
+
+RULES = ("raw", "matched", "innovation")
+
+
+def main():
+ parser = argparse.ArgumentParser()
+ parser.add_argument("--kp_full_gate", default="results/kp_full_gate.json")
+ parser.add_argument("--rule", choices=("all",) + RULES, default="all")
+ parser.add_argument("--device", default="cuda")
+ parser.add_argument("--dry_run", action="store_true")
+ args = parser.parse_args()
+ with open(args.kp_full_gate) as handle:
+ kp_gate = json.load(handle)
+ if kp_gate.get("protocol") != "kolen_pollack_full_v1":
+ raise ValueError("unexpected KP-2 protocol")
+ if kp_gate.get("status") != "passed":
+ raise ValueError("KP-2 did not open MT-1")
+
+ rules = RULES if args.rule == "all" else (args.rule,)
+ os.makedirs("results/kp_innovation_short", exist_ok=True)
+ for rule in rules:
+ command = [
+ sys.executable, "experiments/conv_run.py",
+ "--mode", "kp_traffic", "--traffic_rule", rule,
+ "--device", args.device, "--depth", "20", "--width", "16",
+ "--seed", "0", "--loader_seed", "0", "--batch_size", "128",
+ "--epochs", "20", "--train_limit", "0",
+ "--val_examples", "5000", "--split_seed", "2027",
+ "--eval_split", "validation", "--eval_every", "0",
+ "--augment_train", "1", "--lr", "0.1", "--output_lr", "0.1",
+ "--lr_schedule", "step", "--lr_milestones", "100,150",
+ "--lr_gamma", "0.1", "--warmup_epochs", "0",
+ "--momentum", "0.9", "--weight_decay", "1e-4",
+ "--normalization", "batchnorm", "--a_scale", "1",
+ "--traffic_seed", "4000", "--traffic_ratio", "4",
+ "--traffic_calibration_examples", "64",
+ "--learn_P", "1", "--eta_P", "0.1",
+ "--predictor_warmup_steps", "20", "--predictor_every", "16",
+ "--alignment_probe", "32",
+ "--out", f"results/kp_innovation_short/{rule}.json",
+ ]
+ print(" ".join(command), flush=True)
+ if not args.dry_run:
+ subprocess.run(command, check=True)
+
+
+if __name__ == "__main__":
+ main()