new execute value

hivesolutions · Oct 25, 2015 · 30c687d · 30c687d
1 parent dd1426f
commit 30c687d
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/src/quorum/util.py b/src/quorum/util.py
@@ -786,7 +786,8 @@ def unquote(value, *args, **kwargs):
     if is_bytes: value = value.decode("utf-8")
     return value
 
-def execute(args, command = None, path = None, shell = True):
+def execute(args, command = None, path = None, shell = True, encoding = None):
+    if not encoding: encoding = sys.getfilesystemencoding()
     if command: args = command.split(" ")
     process = subprocess.Popen(
         args,
@@ -796,11 +797,8 @@ def execute(args, command = None, path = None, shell = True):
         cwd = path
     )
     code = process.wait()
-    process.stdout.seek(0)
-    process.stderr.seek(0)
     stdout = process.stdout.read()
     stderr = process.stderr.read()
-    encoding = sys.getfilesystemencoding()
     stdout = stdout.decode(encoding)
     stderr = stderr.decode(encoding)
     return dict(