Skip to content

Commit 39c5b18

Browse files
Using function for proxies
1 parent c666a06 commit 39c5b18

File tree

3 files changed

+20
-8
lines changed

3 files changed

+20
-8
lines changed

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

Lines changed: 12 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -65,10 +65,20 @@ if [[ $CALIB_PHS_RUNBYRUNCALIB == 1 ]]; then
6565
EXTRA_WORKFLOW+="o2-phos-calib-workflow --runbyrun | "
6666
fi
6767

68-
WORKFLOW="o2-dpl-raw-proxy $ARGS_ALL --proxy-name aggregator-proxy --dataspec \"$CALIBDATASPEC\" --channel-config \"name=aggregator-proxy,method=bind,type=pull,rateLogging=1,transport=zeromq,address=tcp://localhost:30453\" | "
68+
# starting with empty workflow
69+
WORKFLOW=
70+
if workflow_has_parameters CALIB_PROXIES; then
71+
if [[ ! -z $CALIBDATASPEC_BARREL ]]; then
72+
WORKFLOW+="o2-dpl-raw-proxy ${ARGS_ALL} --dataspec \"$CALIBDATASPEC_BARREL\" $(get_proxy_connection barrel input) | "
73+
fi
74+
if [[ ! -z $CALIBDATASPEC_CALO ]]; then
75+
WORKFLOW+="o2-dpl-raw-proxy ${ARGS_ALL} --dataspec \"$CALIBDATASPEC_CALO\" $(get_proxy_connection calo input) | "
76+
fi
77+
fi
78+
6979
WORKFLOW+=$EXTRA_WORKFLOW
7080
if [[ $CCDBPATH != "none" ]]; then WORKFLOW+="o2-calibration-ccdb-populator-workflow --ccdb-path $CCDBPATH | "; fi
71-
WORKFLOW+="o2-dpl-run $ARGS_ALL $GLOBALDPLOPT"
81+
WORKFLOW+="o2-dpl-run $ARGS_ALL $GLOBALDPLOPT -b"
7282

7383
if [ $WORKFLOWMODE == "print" ]; then
7484
echo Workflow command:

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

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,8 +15,13 @@ fi
1515
if [[ $CALIB_TPC_SCDCALIB == 1 ]]; then add_W o2-tpc-scdcalib-interpolation-workflow "$DISABLE_ROOT_OUTPUT --disable-root-input --pipeline $(get_N tpc-track-interpolation TPC REST)" "$ITSMFT_FILES"; fi
1616

1717
# output-proxy for aggregator
18-
if [[ ! -z $CALIBDATASPEC ]]; then
19-
WORKFLOW+="o2-dpl-output-proxy ${ARGS_ALL} --dataspec \"$CALIBDATASPEC\" --proxy-channel-name aggregator-proxy --channel-config \"name=aggregator-proxy,method=connect,type=push,transport=zeromq,rateLogging=1,address=tcp://localhost:30453\" | "
18+
if workflow_has_parameters CALIB_PROXIES; then
19+
if [[ ! -z $CALIBDATASPEC_BARREL ]]; then
20+
WORKFLOW+="o2-dpl-output-proxy ${ARGS_ALL} --dataspec \"$CALIBDATASPEC_BARREL\" $(get_proxy_connection barrel output) | "
21+
fi
22+
if [[ ! -z $CALIBDATASPEC_CALO ]]; then
23+
WORKFLOW+="o2-dpl-output-proxy ${ARGS_ALL} --dataspec \"$CALIBDATASPEC_CALO\" $(get_proxy_connection calo output) | "
24+
fi
2025
fi
2126

2227
true # everything OK up to this point, so the script should return 0 (it is !=0 already if a has_detector check fails)

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

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -386,10 +386,7 @@ fi
386386

387387
# ---------------------------------------------------------------------------------------------------------------------
388388
# Calibration workflows
389-
if [[ -z $CALIB_WF ]]; then
390-
CALIB_WF=$MYDIR/calib-workflow.sh
391-
fi
392-
workflow_has_parameter CALIB && { source $CALIB_WF; [[ $? != 0 ]] && exit 1; }
389+
workflow_has_parameter CALIB && { source ${CALIB_WF:-$MYDIR/calib-workflow.sh}; [[ $? != 0 ]] && exit 1; }
393390

394391
# ---------------------------------------------------------------------------------------------------------------------
395392
# Event display

0 commit comments

Comments
 (0)