Merge pull request #60 from airbnb/stdout

Making HiveCliHook.run_cli return stdout
apache · Jun 22, 2015 · 30ea72c · 30ea72c
2 parents 65c5f0a + c00dafe
commit 30ea72c
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/airflow/hooks/hive_hooks.py b/airflow/hooks/hive_hooks.py
@@ -57,13 +57,17 @@ def run_cli(self, hql, schema=None):
                     cwd=tmp_dir)
                 all_err = ''
                 self.sp = sp
+                stdout = ""
                 for line in iter(sp.stdout.readline, ''):
+                    stdout += line
                     logging.info(line.strip())
                 sp.wait()
 
                 if sp.returncode:
                     raise AirflowException(all_err)
 
+                return stdout
+
     def load_file(
             self,
             filepath,