@@ -154,14 +154,22 @@ def pump_stream(cmdline: List[str], name: str, stream: Union[BinaryIO, TextIO],
154154for t in threads :
155155t .join (timeout = kill_after_timeout )
156156if t .is_alive ():
157- if hasattr (process ,'proc' ): # Assume it is a Git.AutoInterrupt:
157+ if isinstance (process ,Git .AutoInterrupt ) :
158158process ._terminate ()
159159else :# Don't want to deal with the other case
160- raise RuntimeError (f "Thread join() timed out in cmd.handle_process_output()."
161- " kill_after_timeout={kill_after_timeout} seconds" )
160+ raise RuntimeError ("Thread join() timed out in cmd.handle_process_output()."
161+ f " kill_after_timeout={ kill_after_timeout }
162162if stderr_handler :
163- stderr_handler ("error: process killed because it timed out."
164- f" kill_after_timeout={ kill_after_timeout } )
163+ error_str :Union [str ,bytes ]= (
164+ "error: process killed because it timed out."
165+ f" kill_after_timeout={ kill_after_timeout } )
166+ if not decode_streams and isinstance (p_stderr ,BinaryIO ):
167+ # Assume stderr_handler needs binary input
168+ error_str = cast (str ,error_str )
169+ error_str = error_str .encode ()
170+ # We ignore typing on the next line because mypy does not like
171+ # the way we infered that stderr takes str of bytes
172+ stderr_handler (error_str )# type: ignore
165173
166174if finalizer :
167175return finalizer (process )
@@ -404,7 +412,7 @@ class AutoInterrupt(object):
404412def __init__ (self ,proc :Union [None ,subprocess .Popen ],args :Any )-> None :
405413self .proc = proc
406414self .args = args
407- self .status = None
415+ self .status : Union [ int , None ] = None
408416
409417def _terminate (self )-> None :
410418"""Terminate the underlying process"""
@@ -447,8 +455,6 @@ def _terminate(self) -> None:
447455call (("TASKKILL /F /T /PID %s 2>nul 1>nul" % str (proc .pid )),shell = True )
448456# END exception handling
449457
450-
451-
452458def __del__ (self )-> None :
453459self ._terminate ()
454460
@@ -465,11 +471,11 @@ def wait(self, stderr: Union[None, str, bytes] = b'') -> int:
465471if stderr is None :
466472stderr_b = b''
467473stderr_b = force_bytes (data = stderr ,encoding = 'utf-8' )
468-
474+ status : Union [ int , None ]
469475if self .proc is not None :
470476status = self .proc .wait ()
471477p_stderr = self .proc .stderr
472- else :# Assume the underlying proc was killed earlier or never existed
478+ else :# Assume the underlying proc was killed earlier or never existed
473479status = self .status
474480p_stderr = None
475481