diff --git a/catalog/dags/common/elasticsearch.py b/catalog/dags/common/elasticsearch.py index 005829b9979..1c2a0493c6d 100644 --- a/catalog/dags/common/elasticsearch.py +++ b/catalog/dags/common/elasticsearch.py @@ -186,6 +186,7 @@ def wait_for_reindex( es_conn = ElasticsearchPythonHook(hosts=[es_host]).get_conn response = es_conn.tasks.get(task_id=task_id) + logger.info(response) count = response.get("task", {}).get("status", {}).get("total") if expected_docs and count != expected_docs: