From ea0b24fb010c6e3f5cca123d46b0d4286f94c826 Mon Sep 17 00:00:00 2001 From: Staci Cooper Date: Tue, 29 Oct 2024 16:08:30 -0700 Subject: [PATCH] Log response in wait_for_reindex --- catalog/dags/common/elasticsearch.py | 1 + 1 file changed, 1 insertion(+) 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: