clean up

Author: ap-atul

pympeg/_filter.py

@@ -664,7 +664,7 @@ def run(caller, display_command=True):
             args=command,
             shell=True,
             stdout=PIPE,
-            stderr=STDOUT,
+            stderr=PIPE,
             universal_newlines=True,
             encoding='utf-8'
             )
@@ -676,7 +676,11 @@ def run(caller, display_command=True):
 
     if code:
         progress.clear()
-        FFmpegException('ffmpeg', "", code)
+        raise FFmpegException(
+                'ffmpeg',
+                ''.join(process.stderr.readlines()[-10: ]),
+                'Error code :: %s' % code
+            )
 
 
 @stream()

pympeg/_node.py

@@ -268,19 +268,19 @@ def __getitem__(self, item):
 
 class GlobalNode:
     """
-        GlobalNode helps in creating some argument based ffmpeg construct that
-        cannot be created using the FilterNode, this takes in the name of the function
-        and its parameter as the string
-
-        Attributes
-        ----------
-        _args : str
-            the complete command
-        _inputs : list
-            input labels for the command
-        _outputs : list
-            output labels for the command
-        """
+    GlobalNode helps in creating some argument based ffmpeg construct that
+    cannot be created using the FilterNode, this takes in the name of the function
+    and its parameter as the string
+
+    Attributes
+    ----------
+    _args : str
+        the complete command
+    _inputs : list
+        input labels for the command
+    _outputs : list
+        output labels for the command
+    """
 
     def __init__(self, inputs=None, args=None, outputs=None):
         self._args = args

pympeg/_probe.py

@@ -8,10 +8,15 @@
 
 def probe(filename, cmd='ffprobe', timeout=None):
     """Runs the ffprobe on the given file and outputs in json format """
+
     args = [cmd, '-show_format', '-show_streams', '-of', 'json']
     args += [filename]
 
-    p = subprocess.Popen(args, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
+    p = subprocess.Popen(
+            args,
+            stdout=subprocess.PIPE,
+            stderr=subprocess.PIPE
+        )
 
     communicate_kwargs = {}
     if timeout is not None: