Workflow 2353, Stage 1

Priority	50
Processors	1
Wall seconds	80000
RSS bytes	4193255424 (3999 MiB)
Max distance for inputs	30.0
Enabled input RSEs	CERN_PDUNE_EOS, DUNE_CERN_EOS, DUNE_ES_PIC, DUNE_FR_CCIN2P3_DISK, DUNE_IN_TIFR, DUNE_IT_INFN_CNAF, DUNE_UK_LANCASTER_CEPH, DUNE_US_BNL_SDCC, DUNE_US_FNAL_DISK_STAGE, FNAL_DCACHE, FNAL_DCACHE_STAGING, FNAL_DCACHE_TEST, MANCHESTER, MONTECARLO, NIKHEF, PRAGUE, QMUL, RAL-PP, RAL_ECHO, SURFSARA, T3_US_NERSC
Enabled output RSEs	CERN_PDUNE_EOS, DUNE_CERN_EOS, DUNE_ES_PIC, DUNE_FR_CCIN2P3_DISK, DUNE_IN_TIFR, DUNE_IT_INFN_CNAF, DUNE_UK_LANCASTER_CEPH, DUNE_US_BNL_SDCC, DUNE_US_FNAL_DISK_STAGE, FNAL_DCACHE, FNAL_DCACHE_STAGING, FNAL_DCACHE_TEST, MANCHESTER, NIKHEF, PRAGUE, QMUL, RAL-PP, RAL_ECHO, SURFSARA, T3_US_NERSC
Enabled sites	CA_SFU, 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_Imperial, UK_Lancaster, UK_Liverpool, UK_Manchester, UK_Oxford, UK_QMUL, 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
Scope	usertests
Events for this stage

Output patterns

	Destination	Pattern	Lifetime	For next stage
1	https://fndcadoor.fnal.gov:2880/dune/scratch/users/calcuttj/justin/keepup_beam_test/test_27304/02353/1	*keepup.root

Environment variables

Name	Value
DETFORMATS_DIR	/cvmfs/fifeuser2.opensciencegrid.org/sw/dune/e92fa537c60f1d9bed1dc1bfc9d1dbcbaaf1058e
DUNERECO_DIR	/cvmfs/fifeuser2.opensciencegrid.org/sw/dune/f28ab8ca1930acc87215b374fda73fb68e9d4c2f
DUNESW_DIR	/cvmfs/fifeuser2.opensciencegrid.org/sw/dune/8b9e6f7e541cea139674057d6cd873b9e996cb3e
LARPANDORA_DIR	/cvmfs/fifeuser2.opensciencegrid.org/sw/dune/13393f7cbb4ae8cb7c81f11f69eea564df142a09
NEVENTS	-1

File states

Total files	Finding	Unallocated	Allocated	Outputting	Processed	Not found	Failed
88	0	0	0	0	84	0	4

Job states

Total	Submitted	Started	Processing	Outputting	Finished	Notused	Aborted	Stalled	Jobscript error	Outputting failed	None processed
231	0	0	0	0	181	0	0	46	0	2	2

RSEs used

Name	Inputs	Outputs
DUNE_CERN_EOS	127	0

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

Site	Allocated	Outputting
IT_CNAF	13	1
CERN	9	0
UK_Manchester	5	0
ES_PIC	3	0
NL_SURFsara	3	0
NL_NIKHEF	2	0
FR_CCIN2P3	2	0
UK_QMUL	1	0

Jobscript

#!/bin/bash
#

source /cvmfs/dune.opensciencegrid.org/products/dune/setup_dune.sh
setup metacat
export METACAT_SERVER_URL=https://metacat.fnal.gov:9443/dune_meta_prod/app
export METACAT_AUTH_SERVER_URL=https://metacat.fnal.gov:8143/auth/dune

if [ -n "${DUNESW_DIR}" ]; then
  stat ${DUNESW_DIR}
  if [ $? -ne 0 ]; then
    echo "failed to stat dunesw dir"
  fi

  export PRODUCTS=$DUNESW_DIR:$PRODUCTS
fi

if [ -n "${DETFORMATS_DIR}" ]; then
  stat ${DETFORMATS_DIR}
  if [ $? -ne 0 ]; then
    echo "failed to stat dunedetdataformats dir"
    exit 1
  fi

  export PRODUCTS=$DETFORMATS_DIR:$PRODUCTS
fi


if [ -n "${LARPANDORA_DIR}" ]; then
  stat ${LARPANDORA_DIR}
  if [ $? -ne 0 ]; then
    echo "failed to stat larpandora dir"
  fi

  export PRODUCTS=$LARPANDORA_DIR:$PRODUCTS
fi

if [ -n "${DUNERECO_DIR}" ]; then
  stat ${DUNERECO_DIR}
  if [ $? -ne 0 ]; then
    echo "failed to stat dunereco dir"
  fi

  export PRODUCTS=$DUNERECO_DIR:$PRODUCTS
fi


echo "PRODUCTS $PRODUCTS"

#Setup recent lar software suite
DUNE_VERSION=${DUNE_VERSION:-v09_90_02d00}
setup dunesw \
   "${DUNE_VERSION}" \
   -q "${DUNE_QUALIFIER:-e26:prof}"

if [ $? -ne 0 ]; then
  echo "Failed to setup dunesw $DUNE_VERSION $DUNE_QUALIFIER"
  exit 1
fi

if [ -n "${USE_INPUT_FCL}" ]; then
  
  if [ -z ${INPUT_DIR} ]; then
    echo "Error, INPUT_DIR is undefined but user requested USE_INPUT_FCL"
    exit 1
  fi

  stat ${INPUT_DIR}
  if [ $? -ne 0 ]; then
    echo "Failed to stat input dir. Exiting safely"
    exit 0
  fi

  FHICL_FILE_PATH=${INPUT_DIR}:${FHICL_FILE_PATH}
  echo "FCL PATH: $FHICL_FILE_PATH"
fi

if [ -n "${METADATA_DIR}" ]; then
  stat ${METADATA_DIR}
  if [ $? -ne 0 ]; then
    echo "failed to stat metadata dir"
  fi

  echo "metadata dir contents:"
  ls $METADATA_DIR
  PYTHONPATH=${METADATA_DIR}:$PYTHONPATH
fi


FCL=${FCL:-"standard_reco_protodunehd_keepup.fcl"}
echo "FCL dump:"
fhicl-dump ${FCL}

echo "DUNESW loc:"
ups active | grep dunesw

if [ -z ${JUSTIN_PROCESSORS} ]; then
  JUSTIN_PROCESSORS=1
fi

echo "Justin processors: ${JUSTIN_PROCESSORS}"

export TF_NUM_THREADS=${JUSTIN_PROCESSORS}   
export OPENBLAS_NUM_THREADS=${JUSTIN_PROCESSORS} 
export JULIA_NUM_THREADS=${JUSTIN_PROCESSORS} 
export MKL_NUM_THREADS=${JUSTIN_PROCESSORS} 
export NUMEXPR_NUM_THREADS=${JUSTIN_PROCESSORS} 
export OMP_NUM_THREADS=${JUSTIN_PROCESSORS}  

echo "printing env"
env

echo "Will use justin-get-file"
#
DID_PFN_RSE=`$JUSTIN_PATH/justin-get-file`
##Check that any file was returned
if [ "${DID_PFN_RSE}" == "" ] ; then
  echo "Could not get file"
  exit 0
fi

pfn=`echo ${DID_PFN_RSE} | cut -f2 -d' '`
did=`echo ${DID_PFN_RSE} | cut -f1 -d' '`
echo "pfn: ${pfn}"
echo "did: ${did}"
now=$(date -u +"%Y%m%dT%H%M%SZ")

nevents=${NEVENTS:--1}

echo "Running reco"
touch reco.log
starttime=`date +"%s"`.0
LD_PRELOAD=$XROOTD_LIB/libXrdPosixPreload.so lar \
    -c ${FCL} \
    -n ${nevents} \
    ${pfn} #>reco.log 2>&1
larExit=$?
endtime=`date +"%s"`.0

if [ $larExit -ne 0 ]; then
  echo "Error in reco"
  cat reco.log
  exit $larExit
fi

output_reco_file=`ls *keepup.root`
#output_mr_file=`ls *keepup_hists.root`
#
#echo "Output files:"
#echo "\tReco: ${output_reco_file}"
#echo "\tHists: ${output_mr_file}"
#
#echo "Forming reco metadata"
#python -m meta_maker --start_time $starttime --end_time $endtime --file_format "artroot" \
#                     --app_family "dunesw" --app_name "reco" --app_version ${DUNE_VERSION} \
#                     --data_tier "full-reconstructed" --get_events -p "$did" \
#                     --fcl $FCL \
#                     -f "${JUSTIN_SCOPE}:$output_reco_file" -j "${output_reco_file}.json"
#echo "Ran successfully"
### TODO -- CHECK
#cat ${output_reco_file}.json
#
#echo "Forming hist metadata"
#python -m meta_maker --start_time $starttime --end_time $endtime --file_format "root" \
#                     --app_family "dunesw" --app_name "reco" --app_version ${DUNE_VERSION} \
#                     --data_tier "root-tuple" -p $output_reco_file.json \
#                     --parent_as_json \
#                     --fcl $FCL \
#                     -f "${JUSTIN_SCOPE}:$output_mr_file" -j "${output_mr_file}.json"
#echo "formed"
#cat ${output_mr_file}.json
#
echo "$pfn" > justin-processed-pfns.txt