Added test to run a hive task and mock out the hive command

test/contrib/hive_test.py

@@ -289,5 +289,21 @@ def test_import_old(self):
         self.assertEquals(luigi.hive, luigi.contrib.hive)
 
 
+class MyHiveTask(hive.HiveQueryTask):
+    param = luigi.Parameter()
+
+    def query(self):
+        return 'banana banana %s' % self.param
+
+
+class TestHiveTask(unittest.TestCase):
+
+    @mock.patch('luigi.hadoop.run_and_track_hadoop_job')
+    def test_run(self, run_and_track_hadoop_job):
+        success = luigi.run(['MyHiveTask', '--param', 'foo', '--local-scheduler', '--no-lock'])
+        self.assertTrue(success)
+        self.assertEquals('hive', run_and_track_hadoop_job.call_args[0][0][0])
+
+
 if __name__ == '__main__':
     unittest.main()