diff --git a/airflow/hooks/druid_hook.py b/airflow/hooks/druid_hook.py index fbd74e8e47d39..48a09e67b20df 100644 --- 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