Add track writer workflow for ITS (#13057)

Author: mconcas

Detectors/ITSMFT/ITS/workflow/CMakeLists.txt

@@ -29,6 +29,7 @@ o2_add_library(ITSWorkflow
                        src/DCSAdaposParserSpec.cxx
                        src/DCSDataGeneratorWorkflow.cxx
                        src/DCSGeneratorSpec.cxx
+                       src/TrackWriterWorkflow.cxx
          PUBLIC_LINK_LIBRARIES O2::Framework
                                O2::SimConfig
                                O2::DetectorsDCS
@@ -58,6 +59,11 @@ o2_add_executable(cluster-writer-workflow
                   COMPONENT_NAME its
                   PUBLIC_LINK_LIBRARIES O2::ITSWorkflow)
 
+o2_add_executable(track-writer-workflow
+                  SOURCES src/its-track-writer-workflow.cxx
+                  COMPONENT_NAME its
+                  PUBLIC_LINK_LIBRARIES O2::ITSWorkflow)
+
 o2_add_executable(cluster-reader-workflow
                   SOURCES src/its-cluster-reader-workflow.cxx
                   COMPONENT_NAME its

Detectors/ITSMFT/ITS/workflow/include/ITSWorkflow/TrackWriterWorkflow.h

@@ -0,0 +1,29 @@
+// Copyright 2019-2020 CERN and copyright holders of ALICE O2.
+// See https://alice-o2.web.cern.ch/copyright for details of the copyright holders.
+// All rights not expressly granted are reserved.
+//
+// This software is distributed under the terms of the GNU General Public
+// License v3 (GPL Version 3), copied verbatim in the file "COPYING".
+//
+// In applying this license CERN does not waive the privileges and immunities
+// granted to it by virtue of its status as an Intergovernmental Organization
+// or submit itself to any jurisdiction.
+
+#ifndef O2_ITS_TRACK_WRITER_WORKFLOW_H
+#define O2_ITS_TRACK_WRITER_WORKFLOW_H
+
+#include "Framework/WorkflowSpec.h"
+
+namespace o2
+{
+namespace its
+{
+
+namespace track_writer_workflow
+{
+framework::WorkflowSpec getWorkflow(bool useMC);
+}
+
+} // namespace its
+} // namespace o2
+#endif

Detectors/ITSMFT/ITS/workflow/src/TrackWriterWorkflow.cxx

@@ -0,0 +1,34 @@
+// Copyright 2019-2020 CERN and copyright holders of ALICE O2.
+// See https://alice-o2.web.cern.ch/copyright for details of the copyright holders.
+// All rights not expressly granted are reserved.
+//
+// This software is distributed under the terms of the GNU General Public
+// License v3 (GPL Version 3), copied verbatim in the file "COPYING".
+//
+// In applying this license CERN does not waive the privileges and immunities
+// granted to it by virtue of its status as an Intergovernmental Organization
+// or submit itself to any jurisdiction.
+
+#include "ITSWorkflow/TrackWriterWorkflow.h"
+#include "ITSWorkflow/TrackWriterSpec.h"
+
+namespace o2
+{
+namespace its
+{
+
+namespace track_writer_workflow
+{
+
+framework::WorkflowSpec getWorkflow(bool useMC)
+{
+  framework::WorkflowSpec specs;
+
+  specs.emplace_back(o2::its::getTrackWriterSpec(useMC));
+
+  return specs;
+}
+
+} // namespace track_writer_workflow
+} // namespace its
+} // namespace o2

Detectors/ITSMFT/ITS/workflow/src/its-track-writer-workflow.cxx

@@ -0,0 +1,36 @@
+// Copyright 2019-2020 CERN and copyright holders of ALICE O2.
+// See https://alice-o2.web.cern.ch/copyright for details of the copyright holders.
+// All rights not expressly granted are reserved.
+//
+// This software is distributed under the terms of the GNU General Public
+// License v3 (GPL Version 3), copied verbatim in the file "COPYING".
+//
+// In applying this license CERN does not waive the privileges and immunities
+// granted to it by virtue of its status as an Intergovernmental Organization
+// or submit itself to any jurisdiction.
+
+#include "ITSWorkflow/TrackWriterWorkflow.h"
+#include "Framework/ConfigParamSpec.h"
+#include "Framework/CompletionPolicyHelpers.h"
+
+using namespace o2::framework;
+
+void customize(std::vector<o2::framework::CompletionPolicy>& policies)
+{
+  // ordered policies for the writers
+  policies.push_back(CompletionPolicyHelpers::consumeWhenAllOrdered(".*(?:ITS|its).*[W,w]riter.*"));
+}
+
+void customize(std::vector<o2::framework::ConfigParamSpec>& workflowOptions)
+{
+  workflowOptions.push_back(ConfigParamSpec{"disable-mc", o2::framework::VariantType::Bool, false, {"disable MC propagation even if available"}});
+}
+
+#include "Framework/runDataProcessing.h"
+#include "Framework/Logger.h"
+
+WorkflowSpec defineDataProcessing(ConfigContext const& configcontext)
+{
+  auto useMC = !configcontext.options().get<bool>("disable-mc");
+  return std::move(o2::its::track_writer_workflow::getWorkflow(useMC));
+}