From 6330535dabfb66934ef80b7164d8cab99c3c2f9a Mon Sep 17 00:00:00 2001
From: David Singh <david@metaphysic.ai>
Date: Fri, 29 Mar 2024 22:44:04 +0700
Subject: [PATCH 1/2] Moved main logic of examples/show_progress.py to a
 separate function

---
 examples/show_progress.py | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/examples/show_progress.py b/examples/show_progress.py
index dd0253a..d5a40bb 100755
--- a/examples/show_progress.py
+++ b/examples/show_progress.py
@@ -108,7 +108,7 @@ def show_progress(total_duration):
             yield socket_filename
 
 
-if __name__ == '__main__':
+def main():
     args = parser.parse_args()
     total_duration = float(ffmpeg.probe(args.in_filename)['format']['duration'])
 
@@ -128,3 +128,6 @@ if __name__ == '__main__':
             print(e.stderr, file=sys.stderr)
             sys.exit(1)
 
+if __name__ == '__main__':
+    main()
+

From 0e26e2dd29df8f6ae93ef31d4ae7db8bddd883aa Mon Sep 17 00:00:00 2001
From: David Singh <david@metaphysic.ai>
Date: Fri, 29 Mar 2024 22:58:29 +0700
Subject: [PATCH 2/2] Fixed monkey patching in examples/show_progress.py

---
 examples/show_progress.py | 14 ++++++++++++--
 1 file changed, 12 insertions(+), 2 deletions(-)

diff --git a/examples/show_progress.py b/examples/show_progress.py
index d5a40bb..083ec94 100755
--- a/examples/show_progress.py
+++ b/examples/show_progress.py
@@ -5,7 +5,7 @@ import argparse
 import contextlib
 import ffmpeg
 import gevent
-import gevent.monkey; gevent.monkey.patch_all(thread=False)
+import gevent.monkey
 import os
 import shutil
 import socket
@@ -62,6 +62,16 @@ def _do_watch_progress(filename, sock, handler):
         connection.close()
 
 
+class PatchSelectors():
+    def __enter__(self):
+        gevent.monkey.patch_selectors(aggressive=False)
+
+    def __exit__(self, *args, **kwargs):
+        import importlib
+        import selectors
+        importlib.reload(selectors)
+
+
 @contextlib.contextmanager
 def _watch_progress(handler):
     """Context manager for creating a unix-domain socket and listen for
@@ -78,7 +88,7 @@ def _watch_progress(handler):
     Yields:
         socket_filename: the name of the socket file.
     """
-    with _tmpdir_scope() as tmpdir:
+    with _tmpdir_scope() as tmpdir, PatchSelectors():
         socket_filename = os.path.join(tmpdir, 'sock')
         sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
         with contextlib.closing(sock):