Merge pull request #18 from schwarzmario/fixes

Fixes for making legend-dataflow work

Author: ggmarshall

src/legenddataflowscripts/par/geds/dsp/evtsel.py

@@ -2,6 +2,7 @@
 
 import argparse
 import json
+import sys
 import time
 import warnings
 from bisect import bisect_left
@@ -99,6 +100,12 @@ def par_geds_dsp_evtsel() -> None:
         required=False,
     )
 
+    argparser.add_argument(
+        "--channel",
+        type=str,
+        help="Channel to process; required if --raw-cal-curve is set",
+        required="--raw-cal-curve" in sys.argv,
+    )
     argparser.add_argument("--log", help="log_file", type=str)
 
     argparser.add_argument(

src/legenddataflowscripts/tier/dsp.py

@@ -95,6 +95,8 @@ def build_tier_dsp() -> None:
         # check if the raw tables are all existing
         if len(lh5.ls(args.input, input_tbl_name)) > 0:
             dsp_cfg_tbl_dict[input_tbl_name] = Props.read_from(file)
+            msg = f"found table {input_tbl_name} in {args.input}"
+            log.debug(msg)
         else:
             msg = f"table {input_tbl_name} not found in {args.input} skipping"
             log.info(msg)
@@ -147,6 +149,8 @@ def build_tier_dsp() -> None:
             kwargs = {
                 "raw_in": args.input,
                 "dsp_out": dsp_files[i],
+                "lh5_tables": list(config.keys()),
+                "base_group": "",
                 "chan_config": config,
                 "database": database_dict,
                 "write_mode": "r",
@@ -173,6 +177,8 @@ def build_tier_dsp() -> None:
         build_dsp(
             raw_in=args.input,
             dsp_out=args.output,
+            lh5_tables=list(dsp_cfg_tbl_dict.keys()),
+            base_group="",
             database=database_dict,
             chan_config=dsp_cfg_tbl_dict,
             write_mode="r",