Skip to content

Commit 7e43d1b

Browse files
committed
Sync workflow: inject missing data at raw-proxy level, and don't expect optional data from TPC
1 parent 912eee8 commit 7e43d1b

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

GPU/Workflow/src/GPUWorkflowSpec.cxx

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1021,7 +1021,7 @@ Inputs GPURecoWorkflowSpec::inputs()
10211021
if (mSpecConfig.zsDecoder) {
10221022
// All ZS raw data is published with subspec 0 by the o2-raw-file-reader-workflow and DataDistribution
10231023
// creates subspec fom CRU and endpoint id, we create one single input route subscribing to all TPC/RAWDATA
1024-
inputs.emplace_back(InputSpec{"zsraw", ConcreteDataTypeMatcher{"TPC", "RAWDATA"}, Lifetime::Optional});
1024+
inputs.emplace_back(InputSpec{"zsraw", ConcreteDataTypeMatcher{"TPC", "RAWDATA"}, Lifetime::Timeframe});
10251025
if (mSpecConfig.askDISTSTF) {
10261026
inputs.emplace_back("stdDist", "FLP", "DISTSUBTIMEFRAME", 0, Lifetime::Timeframe);
10271027
}

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -387,7 +387,7 @@ if [[ ! -z $INPUT_DETECTOR_LIST ]]; then
387387
done
388388
done
389389
[[ ! -z ${TIMEFRAME_RATE_LIMIT:-} ]] && [[ $TIMEFRAME_RATE_LIMIT != 0 ]] && PROXY_CHANNEL+=";name=metric-feedback,type=pull,method=connect,address=ipc://${UDS_PREFIX}metric-feedback-${O2JOBID:-$NUMAID},transport=shmem,rateLogging=0"
390-
add_W o2-dpl-raw-proxy "--dataspec \"$PROXY_INSPEC\" --readout-proxy \"--channel-config \\\"$PROXY_CHANNEL\\\"\" ${TIMEFRAME_SHM_LIMIT+--timeframes-shm-limit} ${TIMEFRAME_SHM_LIMIT:-}" "" 0
390+
add_W o2-dpl-raw-proxy "--dataspec \"$PROXY_INSPEC\" --inject-missing-data --readout-proxy \"--channel-config \\\"$PROXY_CHANNEL\\\"\" ${TIMEFRAME_SHM_LIMIT+--timeframes-shm-limit} ${TIMEFRAME_SHM_LIMIT:-}" "" 0
391391
elif [[ $DIGITINPUT == 1 ]]; then
392392
[[ $NTIMEFRAMES != 1 ]] && { echo "Digit input works only with NTIMEFRAMES=1" 1>&2; exit 1; }
393393
DISABLE_DIGIT_ROOT_INPUT=

0 commit comments

Comments
 (0)