INT           Dashboard       Workflows       Jobs       AWT       Sites       Storages       Docs       Login

Workflow 534, 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-w534s1p1sha1sum-*.txt604800FalseDUNE_US_FNAL_DISK_STAGE

File states

Total filesFindingUnallocatedAllocatedOutputtingProcessedNot foundFailed
4560000439017

Job states

TotalSubmittedStartedProcessingOutputtingFinishedNotusedAbortedStalledJobscript errorOutputting failedNone processed
1374000050202632505840
Files processed0040408080120120160160200200240240280280320320360360Nov-20 19:00Nov-20 20:00Nov-20 21:00Nov-20 22:00Nov-20 23:00Nov-21 00:00Nov-21 01:00Files processedBin start timesNumber per binUS_FNAL-T1US_FNAL-FermiG…US_FNAL-FermiGrid
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_STAGE1300458
DUNE_CA_SFU026
DUNE_US_BNL_SDCC018

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-FermiGrid219492
US_FNAL-T14291

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-21 15:02:00 UTC       justIN version: 01.02.rc5