Skip to content

Commit 8608191

Browse files
authored
Fix #196 (#197)
1 parent dc579f8 commit 8608191

File tree

1 file changed

+9
-3
lines changed

1 file changed

+9
-3
lines changed

src/nectarchain/user_scripts/jlenain/dqm_job_submitter/submit_dqm_processor.py

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -72,11 +72,17 @@
7272

7373
## or from DIRAC FileCatalog directory listing:
7474
processDate = time.Time(args.date)
75-
dfcDir = f"/vo.cta.in2p3.fr/nectarcam/{processDate.ymdhms[0]}/{processDate.ymdhms[0]}{str(processDate.ymdhms[1]).zfill(2)}{str(processDate.ymdhms[2]).zfill(2)}"
75+
dfcDir = (
76+
f"/ctao/nectarcam/NectarCAMQM/{processDate.ymdhms[0]}"
77+
f"/{processDate.ymdhms[0]}{str(processDate.ymdhms[1]).zfill(2)}{str(processDate.ymdhms[2]).zfill(2)}"
78+
)
7679

7780
# The relevant DB file may be stored in the directory corresponding to the day after:
7881
processDateTomorrow = processDate + 1.0 * u.day
79-
dfcDirTomorrow = f"/vo.cta.in2p3.fr/nectarcam/{processDateTomorrow.ymdhms[0]}/{processDateTomorrow.ymdhms[0]}{str(processDateTomorrow.ymdhms[1]).zfill(2)}{str(processDateTomorrow.ymdhms[2]).zfill(2)}"
82+
dfcDirTomorrow = (
83+
f"/ctao/nectarcam/NectarCAMQM/{processDateTomorrow.ymdhms[0]}"
84+
f"/{processDateTomorrow.ymdhms[0]}{str(processDateTomorrow.ymdhms[1]).zfill(2)}{str(processDateTomorrow.ymdhms[2]).zfill(2)}"
85+
)
8086

8187
# Sometimes, for unknown reason, the connection to the DFC can fail, try a few times:
8288
sleep_time = 2
@@ -145,7 +151,7 @@
145151
logger.info(f"Found SQLite files {sqlfilelist} in {dfcDir} and {dfcDirTomorrow}")
146152

147153
# Check already existing DQM outputs
148-
dfcOutDir = "/vo.cta.in2p3.fr/user/j/jlenain/nectarcam/dqm"
154+
dfcOutDir = "/ctao/user/j/jlenain/nectarcam/dqm"
149155
infos = dfc.listDirectory(dfcOutDir)
150156
if not infos["OK"] or not infos["Value"]["Successful"]:
151157
logger.critical(

0 commit comments

Comments
 (0)