|
39 | 39 |
|
40 | 40 | // we need a global variable to propagate the type the message dispatching of the |
41 | 41 | // publisher will trigger on. This is dependent on the input type |
42 | | -static o2::framework::Output gDispatchTrigger{"", ""}; |
| 42 | +static o2::framework::ConcreteDataTypeMatcher gDispatchTrigger{"", ""}; |
43 | 43 |
|
44 | 44 | // Global variable used to transport data to the completion policy |
45 | 45 | static o2::tpc::reco_workflow::CompletionPolicyData gPolicyData; |
@@ -152,13 +152,13 @@ WorkflowSpec defineDataProcessing(ConfigContext const& cfgc) |
152 | 152 | // nothing to do we leave the matcher empty which will suppress the dispatch |
153 | 153 | // trigger and all messages will be sent out together at end of computation |
154 | 154 | } else if (inputType == "digits") { |
155 | | - gDispatchTrigger = o2::framework::Output{"TPC", "DIGITS"}; |
| 155 | + gDispatchTrigger = o2::framework::ConcreteDataTypeMatcher{"TPC", "DIGITS"}; |
156 | 156 | } else if (inputType == "clustershw") { |
157 | | - gDispatchTrigger = o2::framework::Output{"TPC", "CLUSTERHW"}; |
| 157 | + gDispatchTrigger = o2::framework::ConcreteDataTypeMatcher{"TPC", "CLUSTERHW"}; |
158 | 158 | } else if (inputType == "clustersnative") { |
159 | | - gDispatchTrigger = o2::framework::Output{"TPC", "CLUSTERNATIVE"}; |
| 159 | + gDispatchTrigger = o2::framework::ConcreteDataTypeMatcher{"TPC", "CLUSTERNATIVE"}; |
160 | 160 | } else if (inputType == "zsraw") { |
161 | | - gDispatchTrigger = o2::framework::Output{"TPC", "RAWDATA"}; |
| 161 | + gDispatchTrigger = o2::framework::ConcreteDataTypeMatcher{"TPC", "RAWDATA"}; |
162 | 162 | } |
163 | 163 | // set up configuration |
164 | 164 | o2::conf::ConfigurableParam::updateFromFile(cfgc.options().get<std::string>("configFile")); |
|
0 commit comments