[EMCAL-612] Add option to disable decoding errors in cell writer

Needed for converting CTF data into cell trees.

Author: mfasDa

Detectors/EMCAL/workflow/include/EMCALWorkflow/RecoWorkflow.h

@@ -60,7 +60,8 @@ framework::WorkflowSpec getWorkflow(bool propagateMC = true,
                                     std::string const& cfgInput = "digits",
                                     std::string const& cfgOutput = "clusters",
                                     bool disableRootInput = false,
-                                    bool disableRootOutput = false);
+                                    bool disableRootOutput = false,
+                                    bool disableDecodingErrors = false);
 } // namespace reco_workflow
 
 } // namespace emcal

Detectors/EMCAL/workflow/src/RecoWorkflow.cxx

@@ -52,7 +52,8 @@ o2::framework::WorkflowSpec getWorkflow(bool propagateMC,
                                         std::string const& cfgInput,
                                         std::string const& cfgOutput,
                                         bool disableRootInput,
-                                        bool disableRootOutput)
+                                        bool disableRootOutput,
+                                        bool disableDecodingErrors)
 {
 
   const std::unordered_map<std::string, InputType> InputMap{
@@ -240,14 +241,22 @@ o2::framework::WorkflowSpec getWorkflow(bool propagateMC,
                                                            std::move(analysisclusterbranch)));
   };
 
-  auto makeWriterSpec_CellsTR = [checkReady](const char* processName, const char* defaultFileName, const char* defaultTreeName,
-                                             auto&& CellsBranch, auto&& TriggerRecordBranch, auto&& DecoderErrorsBranch) {
+  auto makeWriterSpec_CellsTR = [disableDecodingErrors, checkReady](const char* processName, const char* defaultFileName, const char* defaultTreeName,
+                                                                    auto&& CellsBranch, auto&& TriggerRecordBranch, auto&& DecoderErrorsBranch) {
     return std::move(o2::framework::MakeRootTreeWriterSpec(processName, defaultFileName, defaultTreeName,
                                                            o2::framework::MakeRootTreeWriterSpec::TerminationCondition{checkReady},
                                                            std::move(CellsBranch),
                                                            std::move(TriggerRecordBranch),
                                                            std::move(DecoderErrorsBranch)));
   };
+
+  auto makeWriterSpec_CellsTR_noerrors = [checkReady](const char* processName, const char* defaultFileName, const char* defaultTreeName,
+                                                      auto&& CellsBranch, auto&& TriggerRecordBranch) {
+    return std::move(o2::framework::MakeRootTreeWriterSpec(processName, defaultFileName, defaultTreeName,
+                                                           o2::framework::MakeRootTreeWriterSpec::TerminationCondition{checkReady},
+                                                           std::move(CellsBranch),
+                                                           std::move(TriggerRecordBranch)));
+  };
   /*
     // RS getting input digits and outputing them under the same outputspec will create dependency loop when piping the workflows
   if (isEnabled(OutputType::Digits) && !disableRootOutput) {
@@ -284,19 +293,32 @@ o2::framework::WorkflowSpec getWorkflow(bool propagateMC,
     } else {
       using CellsDataType = std::vector<o2::emcal::Cell>;
       using TriggerRecordDataType = std::vector<o2::emcal::TriggerRecord>;
-      using DecoderErrorsDataType = std::vector<o2::emcal::ErrorTypeFEE>;
-      specs.push_back(makeWriterSpec_CellsTR("emcal-cells-writer",
-                                             "emccells.root",
-                                             "o2sim",
-                                             BranchDefinition<CellsDataType>{o2::framework::InputSpec{"data", "EMC", "CELLS", 0},
-                                                                             "EMCALCell",
-                                                                             "cell-branch-name"},
-                                             BranchDefinition<TriggerRecordDataType>{o2::framework::InputSpec{"trigger", "EMC", "CELLSTRGR", 0},
-                                                                                     "EMCALCellTRGR",
-                                                                                     "celltrigger-branch-name"},
-                                             BranchDefinition<DecoderErrorsDataType>{o2::framework::InputSpec{"errors", "EMC", "DECODERERR", 0},
-                                                                                     "EMCALDECODERERR",
-                                                                                     "decodererror-branch-name"})());
+      if (disableDecodingErrors) {
+        specs.push_back(makeWriterSpec_CellsTR_noerrors("emcal-cells-writer",
+                                                        "emccells.root",
+                                                        "o2sim",
+                                                        BranchDefinition<CellsDataType>{o2::framework::InputSpec{"data", "EMC", "CELLS", 0},
+                                                                                        "EMCALCell",
+                                                                                        "cell-branch-name"},
+                                                        BranchDefinition<TriggerRecordDataType>{o2::framework::InputSpec{"trigger", "EMC", "CELLSTRGR", 0},
+                                                                                                "EMCALCellTRGR",
+                                                                                                "celltrigger-branch-name"})());
+
+      } else {
+        using DecoderErrorsDataType = std::vector<o2::emcal::ErrorTypeFEE>;
+        specs.push_back(makeWriterSpec_CellsTR("emcal-cells-writer",
+                                               "emccells.root",
+                                               "o2sim",
+                                               BranchDefinition<CellsDataType>{o2::framework::InputSpec{"data", "EMC", "CELLS", 0},
+                                                                               "EMCALCell",
+                                                                               "cell-branch-name"},
+                                               BranchDefinition<TriggerRecordDataType>{o2::framework::InputSpec{"trigger", "EMC", "CELLSTRGR", 0},
+                                                                                       "EMCALCellTRGR",
+                                                                                       "celltrigger-branch-name"},
+                                               BranchDefinition<DecoderErrorsDataType>{o2::framework::InputSpec{"errors", "EMC", "DECODERERR", 0},
+                                                                                       "EMCALDECODERERR",
+                                                                                       "decodererror-branch-name"})());
+      }
     }
   }
 

Detectors/EMCAL/workflow/src/emc-reco-workflow.cxx

@@ -37,6 +37,7 @@ void customize(std::vector<o2::framework::ConfigParamSpec>& workflowOptions)
     {"disable-root-output", o2::framework::VariantType::Bool, false, {"do not initialize root file writers"}},
     {"configKeyValues", o2::framework::VariantType::String, "", {"Semicolon separated key=value strings"}},
     {"disable-mc", o2::framework::VariantType::Bool, false, {"disable sending of MC information"}},
+    {"disable-decoding-errors", o2::framework::VariantType::Bool, false, {"disable propagating decoding errors"}},
     {"ignore-dist-stf", o2::framework::VariantType::Bool, false, {"do not subscribe to FLP/DISTSUBTIMEFRAME/0 message (no lost TF recovery)"}},
     {"subspecification", o2::framework::VariantType::Int, 0, {"Subspecification in case the workflow runs in parallel on multiple nodes (i.e. different FLPs)"}}};
 
@@ -69,7 +70,8 @@ o2::framework::WorkflowSpec defineDataProcessing(o2::framework::ConfigContext co
                                                   cfgc.options().get<std::string>("input-type"),
                                                   cfgc.options().get<std::string>("output-type"),
                                                   cfgc.options().get<bool>("disable-root-input"),
-                                                  cfgc.options().get<bool>("disable-root-output"));
+                                                  cfgc.options().get<bool>("disable-root-output"),
+                                                  cfgc.options().get<bool>("disable-decoding-errors"));
 
   // configure dpl timer to inject correct firstTFOrbit: start from the 1st orbit of TF containing 1st sampled orbit
   o2::raw::HBFUtilsInitializer hbfIni(cfgc, wf);