Skip to content

Commit c95c7f7

Browse files
EliEli
authored andcommitted
Log successful NCRO inventory refresh at info level. Reduce some verbose logging in download_des
1 parent 941ec23 commit c95c7f7

2 files changed

Lines changed: 6 additions & 6 deletions

File tree

dms_datastore/download_des.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -366,10 +366,10 @@ def des_download(stations, dest_dir, start, end=None, param=None, overwrite=Fals
366366
if "NFU" in rid.unit_name:
367367
continue
368368
if fend < start:
369-
logger.info(f"skipping one file because fend < {start}")
369+
logger.debug(f"skipping one file because fend < {start}")
370370
continue
371371
if fstart > end:
372-
logger.info(f"skipping one file because fstart > {end}")
372+
logger.debug(f"skipping one file because fstart > {end}")
373373
continue
374374
fstart = max(start, fstart)
375375
fend = min(fend, end)
@@ -416,11 +416,11 @@ def des_download(stations, dest_dir, start, end=None, param=None, overwrite=Fals
416416
write_ts(path, df, meta)
417417

418418
if len(failures) == 0:
419-
logger.info("No failed stations")
419+
logger.info("No failed/unproductive stations")
420420
else:
421-
logger.info("Failed/unproductive query stations: ")
421+
logger.info(f"{len(failures)} failed/unproductive query stations (skipped {len(skips)} existing files)")
422422
for failure in failures:
423-
logger.info(failure)
423+
logger.debug(failure)
424424

425425

426426

dms_datastore/download_ncro.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -283,7 +283,6 @@ def _handle_failed_inventory_refresh(inventory_prev, meta_prev, reason):
283283
reliable_prev = _inventory_is_reliable(inventory_prev)
284284
previous_failed_updates = int(meta_prev.get("failed_updates", 0))
285285
new_failed_updates = previous_failed_updates + 1
286-
287286
if reliable_prev and new_failed_updates <= NCRO_MAX_FAILED_UPDATES:
288287
_write_inventory_file(
289288
inventory_prev,
@@ -338,6 +337,7 @@ def load_inventory(force_update=False):
338337
ncro_inventory = _handle_failed_inventory_refresh(inventory_prev, meta_prev, reason)
339338
return ncro_inventory
340339

340+
logger.info(f"NCRO Inventory: successfully downloaded new inventory with {len(inventory_new)} entries; writing to file")
341341
_write_inventory_file(
342342
inventory_new,
343343
inventoryfile,

0 commit comments

Comments
 (0)