Skip to content

Commit

Permalink
Add debug logging.
Browse files Browse the repository at this point in the history
  • Loading branch information
ktlim committed Jun 24, 2024
1 parent 4560634 commit d143bfd
Showing 1 changed file with 7 additions and 4 deletions.
11 changes: 7 additions & 4 deletions python/lsst/consdb/hinfo.py
Original file line number Diff line number Diff line change
Expand Up @@ -76,7 +76,10 @@ def region(
def ccdexposure_id(
translator: lsst.obs.lsst.translators.lsst.LsstBaseTranslator, exposure_id: int, detector: int
) -> int:
return translator.compute_detector_exposure_id(exposure_id, detector)
global logger
det_exp_id = translator.compute_detector_exposure_id(exposure_id, detector)
logger.debug(f"t={translator}, eid={exposure_id}, d={detector}, cid={det_exp_id}")
return det_exp_id


def ccd_region(
Expand Down Expand Up @@ -360,7 +363,7 @@ def process_resource(resource: ResourcePath, instrument_dict: dict, update: bool
stmt = stmt.on_conflict_do_update(index_elements=["exposure_id"], set_=exposure_rec)
else:
stmt = stmt.on_conflict_do_nothing()
logger.debug(str(stmt))
logger.debug(exposure_rec)
with engine.begin() as conn:
conn.execute(stmt)

Expand All @@ -386,7 +389,7 @@ def process_resource(resource: ResourcePath, instrument_dict: dict, update: bool
)
else:
det_stmt = det_stmt.on_conflict_do_nothing()
logger.debug(str(det_stmt))
logger.debug(det_exposure_rec)
conn.execute(det_stmt)

conn.commit()
Expand Down Expand Up @@ -435,7 +438,7 @@ def get_kafka_config() -> KafkaConfig:
)


logger = setup_logging(__name__)
logger = setup_logging("consdb.hinfo")

instrument = os.environ["INSTRUMENT"]
logger.info(f"Instrument = {instrument}")
Expand Down

0 comments on commit d143bfd

Please sign in to comment.