Upload run_pipeline_batched.py

run_pipeline_batched.py

@@ -80,12 +80,16 @@ def run_batched(
                 case_id=case.id,
             )
 
-            det_contras = check_contradictions(spans, case.question)
-            if det_contras:
+            conflict_result = check_contradictions(spans, case.question)
+            # v0.4: Only FORCED contradictions (status-pair) gate to contradiction.
+            if conflict_result.forced:
                 existing_ids = {c.claim_id for c in verifier_out.claims}
-                for dc in det_contras:
+                for dc in conflict_result.forced:
                     if dc.claim_id not in existing_ids:
                         verifier_out.claims.append(dc)
+            if conflict_result.possible:
+                pc_texts = [pc.claim_text for pc in conflict_result.possible]
+                verifier_out.filter_stats["possible_conflicts"] = pc_texts
 
             gate_out = apply_gate(
                 question=case.question,
@@ -146,7 +150,7 @@ def run_batched(
 def main():
     parser = argparse.ArgumentParser()
     parser.add_argument("--cases", type=str, default=None)
-    parser.add_argument("--output", type=str, default="results/verity_pipeline_v0.3.2.jsonl")
+    parser.add_argument("--output", type=str, default="results/verity_pipeline_v0.4.jsonl")
     parser.add_argument("--batch-size", type=int, default=25, help="Print progress every N cases")
     parser.add_argument("--delay", type=float, default=0.5, help="Seconds between cases")
     parser.add_argument("--skip-calibration", action="store_true")