Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

Merge pull request #277 from cannonpr/master

Update hdfs.py
  • Loading branch information...
commit f1a03389b1bf41523a0ed38e51a393b47760f5d1 2 parents c7805f8 + b250811
@erikbern erikbern authored
Showing with 4 additions and 1 deletion.
  1. +4 −1 luigi/hdfs.py
View
5 luigi/hdfs.py
@@ -67,7 +67,10 @@ def load_hadoop_cmd():
def tmppath(path=None):
# No /tmp//tmp/luigi_tmp_testdir sorts of paths just /tmp/luigi_tmp_testdir.
- if path is not None and path.startswith(tempfile.gettempdir()):
+ hdfs_tmp_dir = configuration.get_config().get('core', 'hdfs-tmp-dir', None)
+ if hdfs_tmp_dir is not None:
+ base = hdfs_tmp_dir
+ elif path is not None and path.startswith(tempfile.gettempdir()):
base = ''
else:
base = tempfile.gettempdir()
Please sign in to comment.
Something went wrong with that request. Please try again.