justIN           Dashboard       Workflows       Jobs       AWT       Sites       Storages       Docs       Login

21 July 2025: This instance at RAL is read-only. Please do not try submitting new workflows for now.

Workflow 7938, Stage 1

Priority50
Processors1
Wall seconds3600
Image/cvmfs/singularity.opensciencegrid.org/fermilab/fnal-wn-sl7:latest
RSS bytes2097152000 (2000 MiB)
Max distance for inputs30.0
Enabled input RSEs CERN_PDUNE_EOS, DUNE_CA_SFU, DUNE_CERN_EOS, DUNE_ES_PIC, DUNE_FR_CCIN2P3_DISK, DUNE_IN_TIFR, DUNE_IT_INFN_CNAF, DUNE_UK_GLASGOW, DUNE_UK_LANCASTER_CEPH, DUNE_UK_MANCHESTER_CEPH, DUNE_US_BNL_SDCC, DUNE_US_FNAL_DISK_STAGE, FNAL_DCACHE, FNAL_DCACHE_STAGING, FNAL_DCACHE_TEST, MONTECARLO, NIKHEF, PRAGUE, QMUL, RAL-PP, RAL_ECHO, SURFSARA, T3_US_NERSC
Enabled output RSEs CERN_PDUNE_EOS, DUNE_CA_SFU, DUNE_CERN_EOS, DUNE_ES_PIC, DUNE_FR_CCIN2P3_DISK, DUNE_IN_TIFR, DUNE_IT_INFN_CNAF, DUNE_UK_GLASGOW, DUNE_UK_LANCASTER_CEPH, DUNE_UK_MANCHESTER_CEPH, DUNE_US_BNL_SDCC, DUNE_US_FNAL_DISK_STAGE, FNAL_DCACHE, FNAL_DCACHE_STAGING, FNAL_DCACHE_TEST, NIKHEF, PRAGUE, QMUL, RAL-PP, RAL_ECHO, SURFSARA, T3_US_NERSC
Enabled sites BR_CBPF, CA_Victoria, CERN, CH_UNIBE-LHEP, CZ_FZU, ES_CIEMAT, ES_PIC, FR_CCIN2P3, IN_TIFR, IT_CNAF, NL_NIKHEF, NL_SURFsara, UK_Bristol, UK_Brunel, UK_Durham, UK_Edinburgh, UK_Lancaster, UK_Manchester, UK_Oxford, UK_QMUL, UK_RAL-PPD, UK_RAL-Tier1, UK_Sheffield, US_Caltech, US_Colorado, US_FNAL-FermiGrid, US_FNAL-T1, US_Michigan, US_MIT, US_Nebraska, US_NotreDame, US_PuertoRico, US_SU-ITS, US_Swan, US_UChicago, US_UConn-HPC, US_UCSD, US_Wisconsin
Scopeusertests
Events for this stage

Output patterns

 DestinationPatternLifetimeFor next stageRSE expression
1https://fndcadoor.fnal.gov:2880/dune/scratch/users/mbrunett/07938/1Pandora_*.pndr

Environment variables

NameValue
INPUT_TAR_DIR_LOCAL/cvmfs/fifeuser3.opensciencegrid.org/sw/dune/0eddb7468140ae94ce8fa1940412eaf5c41db355
NUM_EVENTS1000

File states

Total filesFindingUnallocatedAllocatedOutputtingProcessedNot foundFailed
100001900081000

Job states

TotalSubmittedStartedProcessingOutputtingFinishedNotusedAbortedStalledJobscript errorOutputting failedNone processed
15690000137500192011
Files processed00100100200200300300400400500500600600700700Jun-25 19:00Jun-25 20:00Jun-25 21:00Jun-25 22:00Jun-25 23:00Jun-26 00:00Jun-26 01:00Jun-26 02:00Jun-26 03:00Jun-26 04:00Jun-26 05:00Jun-26 06:00Jun-26 07:00Files processedBin start timesNumber per binUK_RAL-Tier1US_ColoradoUS_MichiganUS_UChicagoUS_PuertoRicoUS_WisconsinUS_FNAL-FermiG…US_FNAL-FermiGridUK_QMUL
Replicas per RSE1000478.91495889807953205.302155864189841000294.0383811204655275.710446316897750318.46951451702074143.94291369570648329.8335185350666136.3297369372531344341.35035764440744130.6477745512538341352.55538445253984126.7419321066604339363.45315065824155124.2955021087191535373.7183019063742123.121362362001864379.16190444480213122.92849200275281379.8603158357401122.92509700062219Replicas per RSEDUNE_US_FNAL_DISK_S…DUNE_US_FNAL_DISK_STAGE (44%)FNAL_DCACHE (44%)PRAGUE (2%)NIKHEF (2%)RAL-PP (1%)SURFSARA (1%)RAL_ECHO (1%)QMUL (1%)DUNE_FR_CCIN2P3_DIS…DUNE_FR_CCIN2P3_DISK (0%)DUNE_ES_PIC (0%)

RSEs used

NameInputsOutputs
DUNE_US_FNAL_DISK_STAGE7400
PRAGUE500
NIKHEF480
RAL-PP440
SURFSARA410
RAL_ECHO390
QMUL350
DUNE_FR_CCIN2P3_DISK40
DUNE_ES_PIC10
None01618

Stats of processed input files as CSV or JSON, and of uploaded output files as CSV or JSON (up to 10000 files included)

File reset events, by site

SiteAllocatedOutputting
US_Wisconsin1190
US_Michigan460
US_PuertoRico130
US_Colorado80
US_NotreDame60

Jobscript

#!/bin/bash
# fcl file and DUNE software version/qualifier to be used
#FCL_FILE=${FCL_FILE:-$INPUT_TAR_DIR_LOCAL/standard_reco2_dune10kt_1x2x6_renamed.fcl}
#FCL_FILE=${FCL_FILE:-$INPUT_TAR_DIR_LOCAL/standard_reco2_dune10kt_1x2x6_pandoraWriterOnly.fcl}
FCL_FILE=${FCL_FILE:-$INPUT_TAR_DIR_LOCAL/standard_reco2_dune10kt_1x2x6_pandoraOnly.fcl}
DUNE_VERSION=${DUNE_VERSION:-v09_81_00d02}
DUNE_QUALIFIER=${DUNE_QUALIFIER:-e26:prof}
FHICL_FILE_PATH=$INPUT_TAR_DIR_LOCAL:$FHICL_FILE_PATH:.
FW_SEARCH_PATH=$INPUT_TAR_DIR_LOCAL:$FW_SEARCH_PATH
echo $FW_SEARCH_PATH

echo "Copying XML"
cp ${INPUT_TAR_DIR_LOCAL}/*.xml .
ls -lrth .

# number of events to process from the input file
if [ "$NUM_EVENTS" != "" ] ; then
 events_option="-n $NUM_EVENTS"
fi

# First get an unprocessed file from this stage
did_pfn_rse=`$JUSTIN_PATH/justin-get-file`

if [ "$did_pfn_rse" = "" ] ; then
  echo "Nothing to process - exit jobscript"
  exit 0
fi

# Keep a record of all input DIDs, for pdjson2meta file -> DID mapping
echo "$did_pfn_rse" | cut -f1 -d' ' >>all-input-dids.txt

# pfn is also needed when creating justin-processed-pfns.txt
pfn=`echo $did_pfn_rse | cut -f2 -d' '`
echo "Input PFN = $pfn"

# Setup DUNE environment
source /cvmfs/dune.opensciencegrid.org/products/dune/setup_dune.sh

# the xroot lib for streaming non-root files is in testproducts,
# so add it to the start of the path
export PRODUCTS=/cvmfs/dune.opensciencegrid.org/products/dune/testproducts:${PRODUCTS}
setup dunesw "$DUNE_VERSION" -q "$DUNE_QUALIFIER"
export OMP_NUM_THREADS=${JUSTIN_PROCESSORS}

# Construct outFile from input $pfn
now=$(date -u +"%Y-%m-%dT_%H%M%SZ")
Ffname=`echo $pfn | awk -F/ '{print $NF}'`
fname=`echo $Ffname | awk -F. '{print $1}'`

campaign="justIN.r${JUSTIN_WORKFLOW_ID}s${JUSTIN_STAGE_ID}"

(
# Do the scary preload stuff in a subshell!
export LD_PRELOAD=${XROOTD_LIB}/libXrdPosixPreload.so
echo "$LD_PRELOAD"

lar -c $FCL_FILE $events_option "$pfn" > ${fname}_reco_${now}.log 2>&1
)

echo "Should have ran the lar code now. Do I have a MCValidation file?"
ls -lrth .

# Subshell exits with exit code of last command
larExit=$?
echo "lar exit code $larExit"
echo "$pfn" > justin-processed-pfns.txt
mv MCValidation.root MCValidation_${fname}.root
mv Pandora_Events_LArCaloHitVersion_2.pndr Pandora_Events_LArCaloHitVersion_2_${fname}.pndr
mv Pandora_Events_LArCaloHitVersion_1.pndr Pandora_Events_LArCaloHitVersion_1_${fname}.pndr

ls -lRS

# Create compressed tar file with all log files
tar zcf `echo "$JUSTIN_JOBSUB_ID.logs.tgz" | sed 's/@/_/g'` *.log
exit $larExit
justIN time: 2025-08-14 16:31:49 UTC       justIN version: 01.03.02