Skip to content

Commit 127b48b

Browse files
committed
Add logging around post-load merge steps of ingest
1 parent 638cf1d commit 127b48b

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

nmdc_server/ingest/all.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -253,5 +253,3 @@ def load(db: Session, function_limit=None, skip_annotation=False):
253253
logger.info("Loading search indices")
254254
search_index.load(db)
255255
db.commit()
256-
257-
logger.info("Ingest finished successfully")

nmdc_server/jobs.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -81,10 +81,15 @@ def do_ingest(function_limit, skip_annotation):
8181
load(ingest_db, function_limit=function_limit, skip_annotation=skip_annotation)
8282

8383
# copy persistent data from the production db to the ingest db
84+
logger.info("Merging file_download")
8485
maybe_merge_download_artifact(ingest_db, prod_db.query(models.FileDownload))
86+
logger.info("Merging bulk_download")
8587
maybe_merge_download_artifact(ingest_db, prod_db.query(models.BulkDownload))
88+
logger.info("Merging bulk_download_data_object")
8689
maybe_merge_download_artifact(ingest_db, prod_db.query(models.BulkDownloadDataObject))
8790

91+
logger.info("Ingest finished successfully")
92+
8893

8994
@celery_app.task
9095
def ingest(function_limit=None, skip_annotation=False):

0 commit comments

Comments
 (0)