blackteay/ffmpeg-python
1
0
Fork 0
mirror of https://github.com/kkroening/ffmpeg-python.git synced 2025-08-07 18:39:47 +08:00
Code Issues Projects Releases Wiki Activity

Adds argument "popen_textmode" for passing through run_async to subprocess.Popen() as argument "text"

Browse Source
This commit is contained in:
Filipe Reis 2019-06-04 16:28:26 +01:00
parent 1b2634291d
commit 5c5a935e4c
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
ffmpeg/_run.py
View File

@ -176,7 +176,7 @@ def compile(stream_spec, cmd='ffmpeg', overwrite_output=False):
@output_operator() @output_operator()
def run_async( def run_async(
stream_spec, cmd='ffmpeg', pipe_stdin=False, pipe_stdout=False, pipe_stderr=False, stream_spec, cmd='ffmpeg', pipe_stdin=False, pipe_stdout=False, pipe_stderr=False,
quiet=False, overwrite_output=False): quiet=False, overwrite_output=False, popen_textmode=None):
"""Asynchronously invoke ffmpeg for the supplied node graph. """Asynchronously invoke ffmpeg for the supplied node graph.
Args: Args:
@ -259,13 +259,13 @@ def run_async(
stdout_stream = subprocess.PIPE if pipe_stdout or quiet else None stdout_stream = subprocess.PIPE if pipe_stdout or quiet else None
stderr_stream = subprocess.PIPE if pipe_stderr or quiet else None stderr_stream = subprocess.PIPE if pipe_stderr or quiet else None
return subprocess.Popen( return subprocess.Popen(
args, stdin=stdin_stream, stdout=stdout_stream, stderr=stderr_stream) args, stdin=stdin_stream, stdout=stdout_stream, stderr=stderr_stream, text=popen_textmode)
@output_operator() @output_operator()
def run( def run(
stream_spec, cmd='ffmpeg', capture_stdout=False, capture_stderr=False, input=None, stream_spec, cmd='ffmpeg', capture_stdout=False, capture_stderr=False, input=None,
quiet=False, overwrite_output=False): quiet=False, overwrite_output=False, popen_textmode=None):
"""Invoke ffmpeg for the supplied node graph. """Invoke ffmpeg for the supplied node graph.
Args: Args:
@ -288,6 +288,7 @@ def run(
pipe_stderr=capture_stderr, pipe_stderr=capture_stderr,
quiet=quiet, quiet=quiet,
overwrite_output=overwrite_output, overwrite_output=overwrite_output,
popen_textmode=popen_textmode,
) )
out, err = process.communicate(input) out, err = process.communicate(input)
retcode = process.poll() retcode = process.poll()