Skip to content

Commit

Permalink
Add more information to log
Browse files Browse the repository at this point in the history
  • Loading branch information
stacimc committed Jun 20, 2023
1 parent 6ba6813 commit 288e069
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion catalog/dags/common/ingestion_server.py
Original file line number Diff line number Diff line change
Expand Up @@ -75,7 +75,10 @@ def response_check_index_readiness_check(response: Response) -> bool:
"""
data = response.json()
hits = data.get("hits", {}).get("total", {}).get("value", 0)
logger.info(f"Retrieved {hits} records from Elasticsearch using the new index.")
logger.info(
f"Retrieved {hits} records from Elasticsearch using the new index."
f" Checking against threshold of {THRESHOLD_RESULT_COUNT}."
)

return hits >= THRESHOLD_RESULT_COUNT

Expand Down

0 comments on commit 288e069

Please sign in to comment.