Skip to content

Commit

Permalink
Remove odeprecated backward-compatibility modules
Browse files Browse the repository at this point in the history
This removes visual ls-clutter when browsing the luigi source tree. And
forces people to update their code. :)
  • Loading branch information
Tarrasch committed Jan 23, 2017
1 parent 6e549ef commit 7f7c476
Show file tree
Hide file tree
Showing 8 changed files with 2 additions and 167 deletions.
4 changes: 2 additions & 2 deletions luigi/contrib/sge.py
Original file line number Diff line number Diff line change
Expand Up @@ -101,7 +101,7 @@ def output(self):
import pickle

import luigi
import luigi.hadoop
from luigi.contrib.hadoop import create_packages_archive
from luigi.contrib import sge_runner

logger = logging.getLogger('luigi-interface')
Expand Down Expand Up @@ -250,7 +250,7 @@ def _init_local(self):
logging.debug("Tarballing dependencies")
# Grab luigi and the module containing the code to be run
packages = [luigi] + [__import__(self.__module__, None, None, 'dummy')]
luigi.hadoop.create_packages_archive(packages, os.path.join(self.tmp_dir, "packages.tar"))
create_packages_archive(packages, os.path.join(self.tmp_dir, "packages.tar"))

def run(self):
if self.run_locally:
Expand Down
26 changes: 0 additions & 26 deletions luigi/hadoop.py

This file was deleted.

27 changes: 0 additions & 27 deletions luigi/hadoop_jar.py

This file was deleted.

27 changes: 0 additions & 27 deletions luigi/hdfs.py

This file was deleted.

27 changes: 0 additions & 27 deletions luigi/hive.py

This file was deleted.

25 changes: 0 additions & 25 deletions luigi/scalding.py

This file was deleted.

26 changes: 0 additions & 26 deletions luigi/webhdfs.py

This file was deleted.

7 changes: 0 additions & 7 deletions test/contrib/hive_test.py
Original file line number Diff line number Diff line change
Expand Up @@ -279,13 +279,6 @@ def test_run_hive_command(self, popen):
self.assertEqual("", returned)


class TestHiveMisc(unittest.TestCase):

def test_import_old(self):
import luigi.hive
self.assertEqual(luigi.hive.HiveQueryTask, luigi.contrib.hive.HiveQueryTask)


class MyHiveTask(luigi.contrib.hive.HiveQueryTask):
param = luigi.Parameter()

Expand Down

0 comments on commit 7f7c476

Please sign in to comment.