From 0e26e2dd29df8f6ae93ef31d4ae7db8bddd883aa Mon Sep 17 00:00:00 2001 From: David Singh Date: Fri, 29 Mar 2024 22:58:29 +0700 Subject: [PATCH] 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):