INT           Dashboard       Workflows       Jobs       AWT       Sites       Storages       Docs       Login

Workflow 531, Stage 1

Priority50
Processors1
Wall seconds80000
RSS bytes2097152000 (2000 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, CA_Victoria, CERN, CH_UNIBE-LHEP, CZ_FZU, ES_CIEMAT, ES_PIC, FR_CCIN2P3, IN_TIFR, IT_CNAF, NL_NIKHEF, NL_SURFsara, RU_JINR, UK_Bristol, UK_Brunel, UK_Durham, UK_Edinburgh, UK_Imperial, UK_Lancaster, UK_Liverpool, UK_Oxford, UK_QMUL, UK_RAL-PPD, UK_RAL-Tier1, UK_Sheffield, US_BNL, 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, US_WSU
Scopetestpro
Events for this stage

Output patterns

 DestinationPatternLifetimeFor next stageRSE expression
1Rucio testpro:test-01-w531s1p1sha1sum-*.txt604800FalseDUNE_US_FNAL_DISK_STAGE

File states

Total filesFindingUnallocatedAllocatedOutputtingProcessedNot foundFailed
456000000456

Job states

TotalSubmittedStartedProcessingOutputtingFinishedNotusedAbortedStalledJobscript errorOutputting failedNone processed
35760000008282027460
Replicas per RSE456475.2844450513829189.48749999999998456380.0354.525456284.71555494861707189.48750000000007Replicas per RSEDUNE_US_FNAL_DISK_STAGE (33%)FNAL_DCACHE (33%)DUNE_CA_SFU (33%)

RSEs used

NameInputsOutputs
DUNE_US_FNAL_DISK_STAGE26550
DUNE_CA_SFU810

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_FNAL-FermiGrid4621693
CA_SFU2053
US_FNAL-T11933

Jobscript

#!/bin/bash
#
# Example jobscript that makes sha1sum checksums of all the files
# referred to by the MQL expression give on the justin command line.
#
# Submit with something like this:
#
# ./justin simple-workflow \
#  --mql "rucio-dataset protodune-sp:np04_raw_run_number_5769" \
#  --scope test --output-pattern 'sha1sum-*.txt:test-01' \
#  --jobscript simple.jobscript 
#
# Then monitor with dashboard or ./justin show-jobs --workflow-id ID
# where ID is the value printed by the first command
#

# Get an unprocessed file from this stage
did_pfn_rse=`$JUSTIN_PATH/justin-get-file`
did=`echo $did_pfn_rse | cut -f1 -d' '`
pfn=`echo $did_pfn_rse | cut -f2 -d' '`
rse=`echo $did_pfn_rse | cut -f3 -d' '`

# These files are found by the wrapper job using the --output-pattern
# form given on the justin command line (see above).
xrdcp --nopbar --debug 1 $pfn tmp
sha1sum tmp >sha1sum-$(date -u +%Y%m%dT%H%M%SZ).txt

# We say we processed whatever we were given
echo "$did" > justin-processed-dids.txt

# Log what we did
echo "Processed $did at $pfn for Workflow $JUSTIN_WORKFLOW_ID, Stage $JUSTIN_STAGE_ID"

exit 0
justIN time: 2024-11-23 15:31:33 UTC       justIN version: 01.02.rc5