Skip to content

Commit 5864cfe

Browse files
committed
dpl-workflow.sh: enable ALPIDE_ERR_DUMPS by default in online physics runs
1 parent b5dfe50 commit 5864cfe

File tree

2 files changed

+13
-4
lines changed

2 files changed

+13
-4
lines changed

Framework/TestWorkflows/src/o2SimpleProcessor.cxx

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -73,15 +73,21 @@ WorkflowSpec defineDataProcessing(ConfigContext const& ctx)
7373
outputs.emplace_back(eosOut);
7474
}
7575

76-
AlgorithmSpec algo = adaptStateful([outputRefs, eosRefs, processingDelay, eosDelay](CallbackService& service) {
76+
AlgorithmSpec algo = adaptStateful([inputs, outputRefs, eosRefs, processingDelay, eosDelay](CallbackService& service) {
7777
service.set<o2::framework::CallbackService::Id::EndOfStream>([eosRefs, eosDelay](EndOfStreamContext&) {
7878
LOG(info) << "Creating objects on end of stream reception.";
7979
std::this_thread::sleep_for(std::chrono::seconds(eosDelay));
8080
});
8181

8282
return adaptStateless(
83-
[outputRefs, processingDelay](InputRecord& inputs, DataAllocator& outputs) {
84-
LOG(info) << "Received " << inputs.size() << " messages. Converting.";
83+
[inputs, outputRefs, processingDelay](InputRecord& inputRec, DataAllocator& outputs) {
84+
LOG(info) << "Received " << inputRec.size() << " messages. Converting.";
85+
if (inputRec.size() > 0 && inputRec.getByPos(0).spec->binding != "enumeration") {
86+
for (size_t i = 0; i < inputRec.size(); ++i) {
87+
LOG(info) << "Getting input " << i << " with binding " << inputRec.getByPos(i).spec->binding;
88+
auto data = inputRec.get<int>(inputs[i].binding);
89+
}
90+
}
8591
auto i = 0;
8692
std::this_thread::sleep_for(std::chrono::milliseconds(processingDelay));
8793
for (auto& ref : outputRefs) {

prodtests/full-system-test/dpl-workflow.sh

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -106,7 +106,10 @@ EVE_OPT=" --jsons-folder $EDJSONS_DIR"
106106
: ${ITSTPC_CONFIG_KEY:=}
107107
: ${AOD_SOURCES:=$TRACK_SOURCES}
108108
: ${AODPROD_OPT:=}
109-
: ${ALPIDE_ERR_DUMPS:=0}
109+
: ${ALPIDE_ERR_DUMPS:=}
110+
if [[ -z $ALPIDE_ERR_DUMPS ]]; then
111+
[[ $EPNSYNCMODE == 1 && $RUNTYPE == "PHYSICS" ]] && ALPIDE_ERR_DUMPS=1 || ALPIDE_ERR_DUMPS=0
112+
fi
110113

111114
[[ "0$DISABLE_ROOT_OUTPUT" == "00" ]] && DISABLE_ROOT_OUTPUT=
112115

0 commit comments

Comments
 (0)