justIN           Dashboard       Workflows       Jobs       AWT       Sites       Storages       Docs       Login

Workflow 244, Stage 1

Priority50
Processors1
Wall seconds80000
Image/cvmfs/singularity.opensciencegrid.org/fermilab/fnal-wn-sl7:latest
RSS bytes4194304000 (4000 MiB)
Max distance for inputs0.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, CERN, CH_UNIBE-LHEP, CZ_FZU, ES_CIEMAT, ES_PIC, FR_CCIN2P3, IT_CNAF, NL_NIKHEF, NL_SURFsara, UK_Bristol, UK_Brunel, UK_Durham, UK_Edinburgh, UK_Glasgow, UK_Imperial, UK_Lancaster, UK_Liverpool, UK_Manchester, UK_Oxford, UK_QMUL, UK_RAL-PPD, UK_RAL-Tier1, UK_Sheffield, US_Colorado, US_FNAL-FermiGrid, US_FNAL-T1, US_Michigan, 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/gpaixao/beam_7GeV/fnal/00244/1*.root

Environment variables

NameValue
INPUT_DIR_LOCAL/cvmfs/fifeuser2.opensciencegrid.org/sw/dune/0db1337f30519bac6c7645c4e8c235833605c68b
nskip0
NUM_EVENTS1

File states

Total filesFindingUnallocatedAllocatedOutputtingProcessedNot foundFailed
00000000

Job states

TotalSubmittedStartedProcessingOutputtingFinishedNotusedAbortedStalledJobscript errorOutputting failedNone processed
000000000000

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

Jobscript

#!/bin/bash

:<<'EOF'
Jobscript para rodar o Run_Photon.fcl e o script_complete.py sobre o mesmo arquivo ROOT de entrada.
EOF

# ------------------------------
# Configuraes do ambiente
# ------------------------------
FCL_FILE=${FCL_FILE:-"$INPUT_DIR_LOCAL/Run_Photon.fcl"}
DUNE_VERSION=${DUNE_VERSION:-v10_07_00d00}
DUNE_QUALIFIER=${DUNE_QUALIFIER:-e26:prof}

# Exporta caminhos para fhicl e plugins
export FHICL_FILE_PATH=${INPUT_DIR_LOCAL}:${FHICL_FILE_PATH}
export FW_SEARCH_PATH=${INPUT_DIR_LOCAL}:${FW_SEARCH_PATH}

# Nmero de eventos e nskip
if [ -n "$NUM_EVENTS" ]; then
  events_option="-n $NUM_EVENTS --nskip $nskip"
fi

# ------------------------------
# Obtm arquivo de entrada via Justin
# ------------------------------
did_pfn_rse=$JUSTIN_PATH/justin-get-file

if [ -z "$did_pfn_rse" ]; then
  echo "[INFO] Nenhum arquivo para processar - encerrando jobscript"
  exit 0
fi

# Registra DID
echo "$did_pfn_rse" | cut -f1 -d' ' >> all-input-dids.txt

# Extrai PFN
pfn=$(echo $did_pfn_rse | cut -f2 -d' ')
echo "[INFO] Arquivo de entrada (PFN) = $pfn"

# ------------------------------
# Configura ambiente DUNE
# ------------------------------
source /cvmfs/dune.opensciencegrid.org/products/dune/setup_dune.sh
setup dunesw "$DUNE_VERSION" -q "$DUNE_QUALIFIER"

# ------------------------------
# Preparao de nomes e logs
# ------------------------------
now=$(date -u +"%Y-%m-%dT_%H%M%SZ")
Ffname=$(basename "$pfn")
fname="${Ffname%%.*}"
lar_log="${fname}_lar_${now}.log"
py_log="${fname}_script_complete_${now}.log"
outFile="pdhd_Photon_hist_${now}.root"

# LD_PRELOAD para XRootD (se necessrio)
export LD_PRELOAD=${XROOTD_LIB}/libXrdPosixPreload.so
echo "[INFO] LD_PRELOAD=$LD_PRELOAD"

# ------------------------------
# Execuo do LArSoft
# ------------------------------
echo "[INFO] Rodando lar com $FCL_FILE no arquivo $pfn"
lar -c "$FCL_FILE" $events_option -o "$outFile" "$pfn" > "$lar_log" 2>&1
larExit=$?

echo '=== ltimas 50 linhas do log do lar ==='
tail -50 "$lar_log"
echo '======================================='

# ------------------------------
# Execuo do script Python no mesmo arquivo ROOT de entrada
# ------------------------------
echo "[INFO] Rodando script_complete.py no mesmo arquivo de entrada"
python "${INPUT_DIR_LOCAL}/script_complete.py" -f "$pfn" > "$py_log" 2>&1
pyExit=$?

echo '=== ltimas 50 linhas do log do Python ==='
tail -50 "$py_log"
echo '=========================================='

# ------------------------------
# Sada final do job
# ------------------------------
if [ $larExit -eq 0 ] && [ $pyExit -eq 0 ]; then
  echo "[INFO] Job finalizado com sucesso"
  exit 0
else
  echo "[ERRO] Falha detectada"
  echo "[ERRO] lar exit code: $larExit"
  echo "[ERRO] python exit code: $pyExit"
  exit 1
fi

justIN time: 2025-08-04 15:54:05 UTC       justIN version: 01.04.00