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

Log query and task_id in druid-hook

Author: awelsh93

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