[AIRFLOW-3195] Log query and task_id in druid-hook (#4018)

Log query and task_id in druid-hook
apache · Oct 12, 2018 · 536c5ab · 536c5ab
1 parent a0489d0
commit 536c5ab
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/airflow/hooks/druid_hook.py b/airflow/hooks/druid_hook.py
@@ -68,6 +68,7 @@ def get_conn_url(self):
     def submit_indexing_job(self, json_index_spec):
         url = self.get_conn_url()
 
+        self.log.info("Druid ingestion spec: {}".format(json_index_spec))
         req_index = requests.post(url, json=json_index_spec, headers=self.header)
         if req_index.status_code != 200:
             raise AirflowException('Did not get 200 when '
@@ -76,6 +77,7 @@ def submit_indexing_job(self, json_index_spec):
         req_json = req_index.json()
         # Wait until the job is completed
         druid_task_id = req_json['task']
+        self.log.info("Druid indexing task-id: {}".format(druid_task_id))
 
         running = True