@@ -46,12 +46,12 @@ generate_mergevbf_submission_script()
4646 CONTAINER_EXTERNAL_DIR=" $CONTAINER_EXTERNAL_DIR -v \" $LOG_DIR :/workdir/external/log/\" "
4747
4848 if [[ $VTSSIMPIPE_CONTAINER == " docker" ]]; then
49- CARE_EXE =" docker run --rm $CONTAINER_EXTERNAL_DIR ${VTSSIMPIPE_CONTAINER_URL}${VTSSIMPIPE_MERGEVBF_IMAGE} "
49+ MERGE_EXE =" docker run --rm $CONTAINER_EXTERNAL_DIR ${VTSSIMPIPE_CONTAINER_URL}${VTSSIMPIPE_MERGEVBF_IMAGE} "
5050 elif [[ $VTSSIMPIPE_CONTAINER == " apptainer" ]]; then
51- CARE_EXE =" apptainer exec --cleanenv ${CONTAINER_EXTERNAL_DIR// -v/ --bind} ${VTSSIMPIPE_CONTAINER_DIR} /${VTSSIMPIPE_MERGEVBF_IMAGE/:/ _} .sif"
51+ MERGE_EXE =" apptainer exec --cleanenv ${CONTAINER_EXTERNAL_DIR// -v/ --bind} ${VTSSIMPIPE_CONTAINER_DIR} /${VTSSIMPIPE_MERGEVBF_IMAGE/:/ _} .sif"
5252 fi
5353
54- batch_size=250
54+ batch_size=251
5555 vbf_id=" 0"
5656 MERGEDFILE=$( get_merge_file_name " $WOBBLE " " $NSB " " $vbf_id " )
5757 TMP_FL_LIST=" $MERGEVBF_DATA_DIR " /tmp_file_list_${WOBBLE} _${NSB} .dat
@@ -68,19 +68,24 @@ generate_mergevbf_submission_script()
6868 echo " MERGEDFILE=$MERGEDFILE "
6969 echo
7070 echo " find \" $CARE_DATA_DIR \" -type f -name \" *.vbf\" -exec basename {} \; | sed 's|^|/workdir/external/care/|' | sort -n > \" $TMP_FL_LIST \" "
71- echo " split -d -l $batch_size \" $TMP_FL_LIST \" \" $TMP_FL_SPLIT_LIST \" "
7271 echo
72+ echo " while read -r file; do"
73+ echo " ${MERGE_EXE} bash -c \" /workdir/VBF/bin/vbfReindex " \$ file" \" "
74+ echo " done < \" $TMP_FL_LIST \" "
75+ echo
76+ echo " split -d -l $batch_size \" $TMP_FL_LIST \" \" $TMP_FL_SPLIT_LIST \" "
7377 echo " for flist in \" $TMP_FL_SPLIT_LIST \" *; do"
7478 echo " RUNNUMBER=\$ (head -n 1 \"\$ flist\" | awk -F '[^0-9]+' '{print \$ 2}')"
75- echo " echo \$ RUNNUMBER"
79+ echo " echo \"\ $ RUNNUMBER\" "
7680 echo " if [[ -e \" ${MERGEVBF_DATA_DIR} /${MERGEDFILE} \$ {RUNNUMBER}.vbf.zst\" ]] && [[ ! -e \" ${MERGEVBF_DATA_DIR} /${MERGEDFILE} \$ {RUNNUMBER}.vbf\" ]]; then"
7781 echo " echo \" Found ${MERGEVBF_DATA_DIR} /${MERGEDFILE} \$ {RUNNUMBER}.vbf.zst; skipping job\" "
7882 echo " continue"
7983 echo " fi"
8084 echo " MERGEVBF=\" ./bin/mergeVBF /workdir/external/mergevbf/\$ (basename \"\$ flist\" ) /workdir/external/mergevbf/\$ {MERGEDFILE}\$ {RUNNUMBER}.vbf \$ {RUNNUMBER}\" "
85+ echo " REINDEX=\" /workdir/VBF/bin/vbfReindex /workdir/external/mergevbf/${MERGEDFILE} \$ {RUNNUMBER}.vbf\" "
8186 echo " ZSTD_VBF=\" zstd -f /workdir/external/mergevbf/${MERGEDFILE} \$ {RUNNUMBER}.vbf\" "
8287 echo " echo \" LOG FILE ${MERGEVBF_DATA_DIR} /${MERGEDFILE} \$ {RUNNUMBER}.log\" "
83- echo " ${CARE_EXE } bash -c \" cd /workdir/EventDisplay_v4 && \$ {MERGEVBF} && \$ {ZSTD_VBF}\" > ${MERGEVBF_DATA_DIR} /${MERGEDFILE} \$ {RUNNUMBER}.log 2>&1"
88+ echo " ${MERGE_EXE } bash -c \" cd /workdir/EventDisplay_v4 && \$ {MERGEVBF} && \$ {REINDEX} && \$ { ZSTD_VBF}\" > ${MERGEVBF_DATA_DIR} /${MERGEDFILE} \"\ $ {RUNNUMBER}\" .log 2>&1"
8489 echo
8590 echo " [ -e \" ${MERGEVBF_DATA_DIR} /${MERGEDFILE} \$ {RUNNUMBER}.vbf.zst\" ] && rm -f \" ${MERGEVBF_DATA_DIR} /${MERGEDFILE} \$ {RUNNUMBER}.vbf\" "
8691 echo " done"
0 commit comments