musicgen_app: make subprocess patching a little more elegant

Author: akx

demos/musicgen_app.py

@@ -11,11 +11,12 @@
 from concurrent.futures import ProcessPoolExecutor
 import os
 from pathlib import Path
-import subprocess as sp
+import subprocess
 from tempfile import NamedTemporaryFile
 import time
 import typing as tp
 import warnings
+from unittest import mock
 
 import torch
 import gradio as gr
@@ -32,18 +33,7 @@
 BATCHED_DURATION = 15
 INTERRUPTING = False
 MBD = None
-# We have to wrap subprocess call to clean a bit the log when using gr.make_waveform
-_old_call = sp.call
 
-
-def _call_nostderr(*args, **kwargs):
-    # Avoid ffmpeg vomiting on the logs.
-    kwargs['stderr'] = sp.DEVNULL
-    kwargs['stdout'] = sp.DEVNULL
-    _old_call(*args, **kwargs)
-
-
-sp.call = _call_nostderr
 # Preallocating the pool of processes.
 pool = ProcessPoolExecutor(4)
 pool.__enter__()
@@ -77,12 +67,20 @@ def _cleanup(self):
 file_cleaner = FileCleaner()
 
 
+def _call_nostderr(*args, **kwargs):
+    # Avoid ffmpeg vomiting on the logs.
+    kwargs['stderr'] = subprocess.DEVNULL
+    kwargs['stdout'] = subprocess.DEVNULL
+    return subprocess.call(*args, **kwargs)
+
+
 def make_waveform(*args, **kwargs):
     # Further remove some warnings.
     be = time.time()
     with warnings.catch_warnings():
         warnings.simplefilter('ignore')
-        out = gr.make_waveform(*args, **kwargs)
+        with mock.patch('subprocess.call', _call_nostderr):
+            out = gr.make_waveform(*args, **kwargs)
         print("Make a video took", time.time() - be)
         return out