fix bug introduced by previous commit

klbostee · Jul 26, 2010 · 3b77a9e · 3b77a9e
1 parent 46b92b0
commit 3b77a9e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/dumbo/backends/streaming.py b/dumbo/backends/streaming.py
@@ -224,7 +224,8 @@ def cat(self, path, opts):
                 # cat each file separately when the path contains special chars
                 ls = os.popen('%s %s/bin/hadoop dfs -ls %s' % \
                               (hadenv, self.hadoop, path))
-                subpaths = (line.split()[-1] for line in ls)
+                subpaths = [line.split()[-1] for line in ls]
+                ls.close()
             else:
                 subpaths = [path]
             for subpath in subpaths:
@@ -240,7 +241,6 @@ def cat(self, path, opts):
                 for output in outputs:
                     print '\t'.join(output)
                 dumptb.close()
-            ls.close()
         except IOError:
             pass  # ignore
         return 0