justIN           Dashboard       Workflows       Jobs       AWT       Sites       Storages       Docs       Login

Workflow 6972, Stage 1

Priority50
Processors1
Wall seconds80000
Image/cvmfs/singularity.opensciencegrid.org/fermilab/fnal-wn-sl7:latest
RSS bytes4194304000 (4000 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_SFU, CA_Victoria, CERN, CH_UNIBE-LHEP, ES_CIEMAT, ES_PIC, FR_CCIN2P3, IN_TIFR, IT_CNAF, 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/ichong/06972/1*

Environment variables

NameValue
CODE_TAR_DIR_LOCAL/cvmfs/fifeuser4.opensciencegrid.org/sw/dune/c976ce192292f2f9835b2b96cb18eba74fad6274
DUNE_QUALIFIERe26:prof
DUNE_VERSIONv10_04_06d00
FCL_FILE/cvmfs/fifeuser3.opensciencegrid.org/sw/dune/5a243cdf1bebd2a8c260c4fcd69b278dcac8660b/atm-training-extract.fcl
NUM_EVENTS10
XML_MASTER/cvmfs/fifeuser3.opensciencegrid.org/sw/dune/5a243cdf1bebd2a8c260c4fcd69b278dcac8660b/PandoraSettings_Master_Training_CSV.xml
XML_NEUTRINO/cvmfs/fifeuser3.opensciencegrid.org/sw/dune/5a243cdf1bebd2a8c260c4fcd69b278dcac8660b/PandoraSettings_Neutrino_Training_CSV.xml

File states

Total filesFindingUnallocatedAllocatedOutputtingProcessedNot foundFailed
5004500104

Job states

TotalSubmittedStartedProcessingOutputtingFinishedNotusedAbortedStalledJobscript errorOutputting failedNone processed
2370000101071082100
Files processed000.10.10.20.20.30.30.40.40.50.50.60.60.70.70.80.80.90.911May-14 20:00May-14 21:00May-14 22:00Files processedBin start timesNumber per binES_PIC
Replicas per RSE50477.0466596654936193.133927913612150341.4201819808837331.9779957011362510277.0354019475429211.9459403307249710298.11476786631596167.79653514797986328.0642611989104142.398858985354373348.4010879344642133.553005240203732360.365756283086130.54669423520182370.1395511520329129.16269009309411377.53149699957675128.7289380079364Replicas per RSEFNAL_DCACHE (37%)PRAGUE (37%)NIKHEF (7%)SURFSARA (7%)QMUL (4%)DUNE_ES_PIC (2%)RAL_ECHO (1%)RAL-PP (1%)DUNE_FR_CCIN2P3_DISK (0%)

RSEs used

NameInputsOutputs
PRAGUE470
NIKHEF180
QMUL170
SURFSARA130
RAL-PP100
RAL_ECHO90
DUNE_ES_PIC80
DUNE_FR_CCIN2P3_DISK60
None014

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
FR_CCIN2P3230
ES_PIC210
UK_RAL-PPD200
CERN170
UK_RAL-Tier1140
UK_Sheffield60
UK_Brunel30

Jobscript

#!/bin/bash
:<<'EOF'
This jobscript is designed to generate CaloHitList-based graph data 
from input reco2 ROOT files using your custom LArSoft setup.

Environment variables used:
  - FCL_FILE
  - CODE_TAR_DIR_LOCAL
  - DUNE_VERSION
  - DUNE_QUALIFIER
  - XML_MASTER
  - XML_NEUTRINO
  - NUM_EVENTS (optional)
EOF

# === Setup FCL and version info ===
FCL_FILE=${FCL_FILE:-atm-training-extract.fcl}
DUNE_VERSION=${DUNE_VERSION:-v10_04_06d00}
DUNE_QUALIFIER=${DUNE_QUALIFIER:-e26:prof}
HAS_ART_OUTPUT=false

# === Number of events ===
if [ -n "$NUM_EVENTS" ]; then
  events_option="-n $NUM_EVENTS"
fi

# === Get a file from justIN ===
did_pfn_rse=$($JUSTIN_PATH/justin-get-file)
if [ -z "$did_pfn_rse" ]; then
  echo "No file assigned. Exiting jobscript."
  exit 0
fi

# === Parse PFN from did_pfn_rse ===
pfn=$(echo "$did_pfn_rse" | cut -d' ' -f2)
echo "Input PFN = $pfn"

# === DUNE software setup ===
source /cvmfs/dune.opensciencegrid.org/products/dune/setup_dune.sh
export PRODUCTS=/cvmfs/dune.opensciencegrid.org/products/dune/testproducts:${PRODUCTS}
setup dunesw "$DUNE_VERSION" -q "$DUNE_QUALIFIER"

# === Custom local products ===
if [ -n "$CODE_TAR_DIR_LOCAL" ]; then
  echo "Loading local LArSoft from $CODE_TAR_DIR_LOCAL"
  source ${CODE_TAR_DIR_LOCAL}/*/localProducts*/setup
  mrbslp
fi

# === Output file naming ===
now=$(date -u +"%Y-%m-%dT_%H%M%SZ")
fname=$(basename "$pfn" .root)

# === Set FW search path to include both XML directories ===
XML_DIR_MASTER=$(dirname "$XML_MASTER")
XML_DIR_NEUTRINO=$(dirname "$XML_NEUTRINO")
export FW_SEARCH_PATH="$XML_DIR_MASTER:$XML_DIR_NEUTRINO:$FW_SEARCH_PATH"

# === Run lar ===
export LD_PRELOAD=${XROOTD_LIB}/libXrdPosixPreload.so
echo "Running LArSoft with FCL: $FCL_FILE"
lar -c "$FCL_FILE" $events_option "$pfn" > ${fname}_graph_${now}.log 2>&1
larExit=$?
# === Mark processed if successful ===
if [ $larExit -eq 0 ]; then
  echo "$pfn" > justin-processed-pfns.txt
  jobscriptExit=0
else
  jobscriptExit=1
fi

# === Package logs ===
tar zcf "${JUSTIN_JOBSUB_ID}.logs.tgz" *.log

# === Rename .data files ===
data_files=$(ls -1 *.data 2>/dev/null)
if [ -n "$data_files" ]; then
  for f in $data_files; do
    base=$(basename "$f" .data)
    new_name="${base}__${fname}__${JUSTIN_JOBSUB_ID}.data"
    mv "$f" "$new_name"
  done
else
  echo "No .data files to rename."
fi


# === Show generated .data files ===
echo "=== Generated .data files ==="
data_files=$(ls -1 *.data 2>/dev/null)
if [ -n "$data_files" ]; then
  echo "$data_files"
else
  echo "No .data files found."
fi

# === Export log content for Justin dashboard ===
echo "=== Last 100 lines of log (for dashboard display) ==="
tail -n 100 ${fname}_graph_${now}.log > jobscript.log
cat jobscript.log

ls -lh *.data *.log || true

exit $jobscriptExit
justIN time: 2025-05-23 09:43:15 UTC       justIN version: 01.03.01