1111import subprocess # noqa: S404
1212import sys
1313from asyncio import StreamReader
14+ from collections .abc import Sequence
1415from importlib .metadata import PackageNotFoundError , version
1516from pathlib import Path
1617from shlex import join
17- from typing import TYPE_CHECKING , Any , Sequence
18+ from typing import TYPE_CHECKING , Any
1819
1920try :
2021 __version__ = version ("subprocess-tee" )
2627
2728if TYPE_CHECKING :
2829 from collections .abc import Callable
30+
2931 from subprocess_tee ._types import StrOrBytesPath
3032CompletedProcess = subprocess .CompletedProcess
3133
@@ -41,7 +43,7 @@ async def _read_stream(stream: StreamReader, callback: Callable[..., Any]) -> No
4143 break
4244
4345
44- async def _stream_subprocess ( # noqa: C901, R0913, R0914
46+ async def _stream_subprocess ( # noqa: C901
4547 args : StrOrBytesPath | Sequence [StrOrBytesPath ],
4648 * ,
4749 stdin = None ,
@@ -201,7 +203,11 @@ def run(
201203 check = kwargs .get ("check" , False )
202204
203205 if kwargs .pop ("echo" , False ):
204- cmd = args if isinstance (args , (str , bytes , os .PathLike )) else join (str (s ) for s in args )
206+ cmd = (
207+ args
208+ if isinstance (args , (str , bytes , os .PathLike ))
209+ else join (str (s ) for s in args )
210+ )
205211 print (f"COMMAND: { cmd } " ) # noqa: T201
206212
207213 result = asyncio .run (_stream_subprocess (args , ** kwargs ))
0 commit comments