Skip to content

Commit

Permalink
Remove probably unnecessary and harmful completion policy
Browse files Browse the repository at this point in the history
  • Loading branch information
wiechula committed Jan 22, 2024
1 parent 88d397a commit 76741c7
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 26 deletions.
13 changes: 0 additions & 13 deletions Detectors/TPC/workflow/src/tpc-krypton-clusterer.cxx
Original file line number Diff line number Diff line change
Expand Up @@ -38,19 +38,6 @@ using namespace o2::tpc;
std::vector<InputSpec> gPolicyData;
unsigned long gTpcSectorMask = 0xFFFFFFFFF;

// customize the completion policy
void customize(std::vector<o2::framework::CompletionPolicy>& policies)
{
using o2::framework::CompletionPolicy;
policies.push_back(CompletionPolicyHelpers::defineByName("tpc-krypton-clusterer.*", CompletionPolicy::CompletionOp::Consume));
// policies.push_back(CompletionPolicyHelpers::defineByName("file-writer", CompletionPolicy::CompletionOp::Consume));

// we customize the pipeline processors to consume data as it comes
//
// the custom completion policy for the tracker
policies.push_back(o2::tpc::TPCSectorCompletionPolicy("file-writer", o2::tpc::TPCSectorCompletionPolicy::Config::RequireAll, &gPolicyData, &gTpcSectorMask)());
}

// we need to add workflow options before including Framework/runDataProcessing
void customize(std::vector<ConfigParamSpec>& workflowOptions)
{
Expand Down
13 changes: 0 additions & 13 deletions Detectors/TPC/workflow/src/tpc-krypton-raw-filter.cxx
Original file line number Diff line number Diff line change
Expand Up @@ -41,19 +41,6 @@ using namespace o2::tpc;
std::vector<InputSpec> gPolicyData;
unsigned long gTpcSectorMask = 0xFFFFFFFFF;

// customize the completion policy
void customize(std::vector<o2::framework::CompletionPolicy>& policies)
{
using o2::framework::CompletionPolicy;
policies.push_back(CompletionPolicyHelpers::defineByName("tpc-krypton-raw-filter.*", CompletionPolicy::CompletionOp::Consume));
// policies.push_back(CompletionPolicyHelpers::defineByName("file-writer", CompletionPolicy::CompletionOp::Consume));

// we customize the pipeline processors to consume data as it comes
//
// the custom completion policy for the tracker
policies.push_back(o2::tpc::TPCSectorCompletionPolicy("file-writer", o2::tpc::TPCSectorCompletionPolicy::Config::RequireAll, &gPolicyData, &gTpcSectorMask)());
}

// we need to add workflow options before including Framework/runDataProcessing
void customize(std::vector<ConfigParamSpec>& workflowOptions)
{
Expand Down

0 comments on commit 76741c7

Please sign in to comment.