Cleanup and rename campaign scripts

Author: DraTeots

csv_convert/convert_campaign.py csv_convert/convert_edm4eic.pycsv_convert/convert_campaign.py renamed to csv_convert/convert_edm4eic.py

@@ -5,10 +5,10 @@
 
 
 help_txt = """
-convert_lambda.py  –  run csv_mcpart_lambda.cxx on every *.edm4eic.root file
+convert_edm4eic.py - run csv_mcpart_lambda.cxx on every *.edm4eic.root file
 
 Usage:
-    python3 convert_lambda.py [directory] [macro]
+    python3 convert_edm4eic.py [directory] [macro]
 
 Arguments (all optional)
     directory : where to search for ROOT files

csv_convert/convert_edm4hep.py

@@ -0,0 +1,61 @@
+#!/usr/bin/env python3
+import subprocess
+import sys
+from pathlib import Path
+
+
+help_txt = """
+runs csv_*.cxx on every *.edm4hep.root file
+
+Usage:
+    python3 convert_edm4hep.py [directory]
+
+Arguments (all optional)
+    directory : where to search for ROOT files
+"""
+
+
+# --- Config ---
+
+if len(sys.argv) < 2:
+    print("Provide directory path as an argument.")
+    print(help_txt)
+    exit(1)
+
+input_dir = Path(sys.argv[1])
+macros = [
+    "csv_edm4hep_acceptance_npi0.cxx",
+    "csv_edm4hep_acceptance_ppim.cxx",
+]
+
+
+# --- Find files ---
+root_files = sorted(input_dir.glob("*.edm4hep.root"))
+file_count = len(root_files)
+if file_count == 0:
+    sys.exit(f"[ERROR] No *.edm4hep.root files found in {input_dir}")
+
+print(f"[INFO] Found {file_count} .edm4hep.root files in {input_dir}\n")
+
+# ------------------------------------------------------------------ run loop
+for idx, file_path in enumerate(root_files, start=1):
+    print(f"[{idx}/{file_count}] ============================================")
+    for macro in macros:
+        macro_base_name = macro.replace("csv_", "").replace(".cxx", "")
+        out_file = file_path.with_name(file_path.name.replace(".edm4hep.root",  f".{macro_base_name}.csv"))
+        if out_file.exists():
+            print(f"[SKIP] {out_file.name} already exists, skipping")
+            continue
+
+        print(f"|{macro}|  {file_path.name} → {out_file.name}")
+        cmd = [
+            "root", "-x", "-l", "-b", "-q",
+            f'{macro}("{file_path}","{out_file}")'
+        ]
+        try:
+            subprocess.run(cmd, check=True)
+        except subprocess.CalledProcessError as e:
+            print(f"[ERROR] Failed on {file_path.name}: exit code {e.returncode}")
+            sys.exit(1)
+    print(f"---> Finished converting: {file_path.name}")
+print(f"\n[OK] Successfully processed {file_count} files. Output CSVs are alongside the ROOT files.")

…ipeline/root_hepmc_k_lambda_converter.py …m-pipeline/01_root_hepmc_klam_convert.pyfull-sim-pipeline/root_hepmc_k_lambda_converter.py renamed to full-sim-pipeline/01_root_hepmc_klam_convert.py full-sim-pipeline/root_hepmc_k_lambda_converter.py renamed to full-sim-pipeline/01_root_hepmc_klam_convert.py

@@ -134,11 +134,8 @@ def main():
     config = load_config()
     energies = config.get('energies', [])
 
-    print("="*80)
-    print("CSV CONVERSION PIPELINE")
-    print("="*80)
-    print(f"Energies to process: {energies}")
-    print("")
+    print(f"{'='*80}\n CSV CONVERSION PIPELINE\n{'='*80}")
+    print(f"Energies to process: {energies}\n")
 
     # Process each energy
     for energy in energies:

full-sim-pipeline/root_hepmc_converter.py …im-pipeline/02_root_hepmc_pin_convert.pyfull-sim-pipeline/root_hepmc_converter.py renamed to full-sim-pipeline/02_root_hepmc_pin_convert.py full-sim-pipeline/root_hepmc_converter.py renamed to full-sim-pipeline/02_root_hepmc_pin_convert.py

@@ -39,10 +39,13 @@ afterburner_output: "${base_dir}/afterburner/${energy}${priority}"
 
 
 # DD4Hep jobs
+# afterburner_output is input here
 dd4hep_output: "${base_dir}/dd4hep/${energy}${priority}"
 
-# DD4Hep jobs
+# EICrecon jobs
+# dd4hep_output is input here
 eicrecon_output: "${base_dir}/reco/${energy}${priority}"
 
 # Where to put CSV output
+# eicrecon_output and dd4hep_output are inputs here
 csv_output: "${base_dir}/csv/${energy}${priority}"