@@ -292,28 +292,32 @@ def refresh(cls, path: Union[None, PathLike] = None) -> bool:
292
292
# revert to whatever the old_git was
293
293
cls .GIT_PYTHON_GIT_EXECUTABLE = old_git
294
294
295
- if old_git is None :
296
- # on the first refresh (when GIT_PYTHON_GIT_EXECUTABLE is
297
- # None) we only are quiet, warn, or error depending on the
298
- # GIT_PYTHON_REFRESH value
299
-
300
- # determine what the user wants to happen during the initial
301
- # refresh we expect GIT_PYTHON_REFRESH to either be unset or
302
- # be one of the following values:
303
- # 0|q|quiet|s|silence
304
- # 1|w|warn|warning
305
- # 2|r|raise|e|error
306
-
307
- mode = os .environ .get (cls ._refresh_env_var , "raise" ).lower ()
308
-
309
- quiet = ["quiet" , "q" , "silence" , "s" , "none" , "n" , "0" ]
310
- warn = ["warn" , "w" , "warning" , "1" ]
311
- error = ["error" , "e" , "raise" , "r" , "2" ]
312
-
313
- if mode in quiet :
314
- pass
315
- elif mode in warn or mode in error :
316
- err = dedent ("""\
295
+ if old_git is not None :
296
+ # after the first refresh (when GIT_PYTHON_GIT_EXECUTABLE
297
+ # is no longer None) we raise an exception
298
+ raise GitCommandNotFound ("git" , err )
299
+
300
+ # on the first refresh (when GIT_PYTHON_GIT_EXECUTABLE is
301
+ # None) we only are quiet, warn, or error depending on the
302
+ # GIT_PYTHON_REFRESH value
303
+
304
+ # determine what the user wants to happen during the initial
305
+ # refresh we expect GIT_PYTHON_REFRESH to either be unset or
306
+ # be one of the following values:
307
+ # 0|q|quiet|s|silence
308
+ # 1|w|warn|warning
309
+ # 2|r|raise|e|error
310
+
311
+ mode = os .environ .get (cls ._refresh_env_var , "raise" ).lower ()
312
+
313
+ quiet = ["quiet" , "q" , "silence" , "s" , "none" , "n" , "0" ]
314
+ warn = ["warn" , "w" , "warning" , "1" ]
315
+ error = ["error" , "e" , "raise" , "r" , "2" ]
316
+
317
+ if mode in quiet :
318
+ pass
319
+ elif mode in warn or mode in error :
320
+ err = dedent ("""\
317
321
%s
318
322
All git commands will error until this is rectified.
319
323
@@ -326,43 +330,38 @@ def refresh(cls, path: Union[None, PathLike] = None) -> bool:
326
330
Example:
327
331
export %s=%s
328
332
""" ) % (
329
- err ,
330
- cls ._refresh_env_var ,
331
- "|" .join (quiet ),
332
- "|" .join (warn ),
333
- "|" .join (error ),
334
- cls ._refresh_env_var ,
335
- quiet [0 ])
336
-
337
- if mode in warn :
338
- print ("WARNING: %s" % err )
339
- else :
340
- raise ImportError (err )
333
+ err ,
334
+ cls ._refresh_env_var ,
335
+ "|" .join (quiet ),
336
+ "|" .join (warn ),
337
+ "|" .join (error ),
338
+ cls ._refresh_env_var ,
339
+ quiet [0 ])
340
+
341
+ if mode in warn :
342
+ print ("WARNING: %s" % err )
341
343
else :
342
- err = dedent ("""\
344
+ raise ImportError (err )
345
+ else :
346
+ err = dedent ("""\
343
347
%s environment variable has been set but it has been set with an invalid value.
344
348
345
349
Use only the following values:
346
350
- %s: for no warning or exception
347
351
- %s: for a printed warning
348
352
- %s: for a raised exception
349
353
""" ) % (
350
- cls ._refresh_env_var ,
351
- "|" .join (quiet ),
352
- "|" .join (warn ),
353
- "|" .join (error ))
354
- raise ImportError (err )
355
-
356
- # we get here if this was the init refresh and the refresh mode
357
- # was not error, go ahead and set the GIT_PYTHON_GIT_EXECUTABLE
358
- # such that we discern the difference between a first import
359
- # and a second import
360
- cls .GIT_PYTHON_GIT_EXECUTABLE = cls .git_exec_name
361
- else :
362
- # after the first refresh (when GIT_PYTHON_GIT_EXECUTABLE
363
- # is no longer None) we raise an exception
364
- raise GitCommandNotFound ("git" , err )
365
-
354
+ cls ._refresh_env_var ,
355
+ "|" .join (quiet ),
356
+ "|" .join (warn ),
357
+ "|" .join (error ))
358
+ raise ImportError (err )
359
+
360
+ # we get here if this was the init refresh and the refresh mode
361
+ # was not error, go ahead and set the GIT_PYTHON_GIT_EXECUTABLE
362
+ # such that we discern the difference between a first import
363
+ # and a second import
364
+ cls .GIT_PYTHON_GIT_EXECUTABLE = cls .git_exec_name
366
365
return has_git
367
366
368
367
@classmethod
@@ -485,12 +484,11 @@ def wait(self, stderr: Union[None, str, bytes] = b'') -> int:
485
484
p_stderr = None
486
485
487
486
def read_all_from_possibly_closed_stream (stream : Union [IO [bytes ], None ]) -> bytes :
488
- if stream :
489
- try :
490
- return stderr_b + force_bytes (stream .read ())
491
- except ValueError :
492
- return stderr_b or b''
493
- else :
487
+ if not stream :
488
+ return stderr_b or b''
489
+ try :
490
+ return stderr_b + force_bytes (stream .read ())
491
+ except ValueError :
494
492
return stderr_b or b''
495
493
496
494
# END status handling
@@ -529,12 +527,7 @@ def read(self, size: int = -1) -> bytes:
529
527
bytes_left = self ._size - self ._nbr
530
528
if bytes_left == 0 :
531
529
return b''
532
- if size > - 1 :
533
- # assure we don't try to read past our limit
534
- size = min (bytes_left , size )
535
- else :
536
- # they try to read all, make sure its not more than what remains
537
- size = bytes_left
530
+ size = min (bytes_left , size ) if size > - 1 else bytes_left
538
531
# END check early depletion
539
532
data = self ._stream .read (size )
540
533
self ._nbr += len (data )
@@ -551,10 +544,7 @@ def readline(self, size: int = -1) -> bytes:
551
544
552
545
# clamp size to lowest allowed value
553
546
bytes_left = self ._size - self ._nbr
554
- if size > - 1 :
555
- size = min (bytes_left , size )
556
- else :
557
- size = bytes_left
547
+ size = min (bytes_left , size ) if size > - 1 else bytes_left
558
548
# END handle size
559
549
560
550
data = self ._stream .readline (size )
@@ -602,8 +592,7 @@ def next(self) -> bytes:
602
592
return line
603
593
604
594
def __del__ (self ) -> None :
605
- bytes_left = self ._size - self ._nbr
606
- if bytes_left :
595
+ if bytes_left := self ._size - self ._nbr :
607
596
# read and discard - seeking is impossible within a stream
608
597
# includes terminating newline
609
598
self ._stream .read (bytes_left + 1 )
@@ -1040,19 +1029,13 @@ def custom_environment(self, **kwargs: Any) -> Iterator[None]:
1040
1029
self .update_environment (** old_env )
1041
1030
1042
1031
def transform_kwarg (self , name : str , value : Any , split_single_char_options : bool ) -> List [str ]:
1043
- if len (name ) == 1 :
1044
- if value is True :
1045
- return ["-%s" % name ]
1046
- elif value not in (False , None ):
1047
- if split_single_char_options :
1048
- return ["-%s" % name , "%s" % value ]
1049
- else :
1050
- return ["-%s%s" % (name , value )]
1051
- else :
1052
- if value is True :
1053
- return ["--%s" % dashify (name )]
1054
- elif value is not False and value is not None :
1055
- return ["--%s=%s" % (dashify (name ), value )]
1032
+ if value is True :
1033
+ return ["-%s" % name ] if len (name ) == 1 else ["--%s" % dashify (name )]
1034
+ elif value not in (False , None ):
1035
+ if split_single_char_options :
1036
+ return ["-%s" % name , "%s" % value ]
1037
+ else :
1038
+ return ["-%s%s" % (name , value )]
1056
1039
return []
1057
1040
1058
1041
def transform_kwargs (self , split_single_char_options : bool = True , ** kwargs : Any ) -> List [str ]:
0 commit comments