Hlt/Moore/python/Moore/__init__.py

@@ -14,3 +14,4 @@
 # flake8: noqa
 from .config import (options, run_moore, run_reconstruction,
                      moore_control_flow, run_allen, run_allen_reconstruction)
+from .lbexec import Options

Hlt/Moore/python/Moore/config.py

@@ -166,7 +166,8 @@ def setup_ann_service(hlt1_decision_ids, hlt2_decision_ids,
 
 
 @configurable
-def report_writers_node(streams,
+def report_writers_node(options,
+                        streams,
                         data_type,
                         process,
                         associate_mc=False,
@@ -297,7 +298,8 @@ def report_writers_node(streams,
 
 
 @configurable
-def stream_writer(stream,
+def stream_writer(options,
+                  stream,
                   path,
                   output_type,
                   process,
@@ -495,6 +497,7 @@ def moore_control_flow(options, streams, process, allen_hlt1):
     setup_ann_service(**ann_config)
 
     rw_node, new_raw_banks, extra_outputs, barriers, decreports_loc = report_writers_node(
+        options,
         streams,
         options.data_type,
         process,
@@ -547,7 +550,7 @@ def moore_control_flow(options, streams, process, allen_hlt1):
                                     stream_bank_types(stream))
 
             pre_algs, post_algs = stream_writer(
-                stream, options.output_file, options.output_type, process,
+                options, stream, options.output_file, options.output_type, process,
                 list(new_raw_banks.values()), persist_types, extra_outputs)
             stream_writers_setup += pre_algs
 
@@ -708,7 +711,7 @@ def allen_control_flow(options):
         # Will not change output file name
         stream = "default"
         pre_algs, post_algs = stream_writer(
-            stream, options.output_file, options.output_type, "hlt1",
+            options, stream, options.output_file, options.output_type, "hlt1",
             list(new_hlt_banks.values()), input_raw_bank_types)
         writer_setup += pre_algs
         writers += post_algs

Hlt/Moore/python/Moore/lbexec.py

+from pathlib import Path
+from typing import Optional
+
+from pydantic import FilePath
+
+from GaudiConf.lbexec import Options as DefaultOptions
+
+
+class Options(DefaultOptions):
+    annsvc_config: FilePath
+
+    input_raw_format: float
+
+    # reco_from_file: bool = True
+    # spruce: bool = False
+    buffer_events: int = 20000
+
+    tck: Optional[int] = None