Remove unnecessary parentheses on return statements

Author: ronf

asyncssh/channel.py

@@ -2065,16 +2065,16 @@ async def connect(self, session_factory: SSHTCPSessionFactory[AnyStr],
             SSHTCPSession[AnyStr]:
         """Create a new outbound TCP session"""
 
-        return (await self._open_tcp(session_factory, b'direct-tcpip',
-                                     host, port, orig_host, orig_port))
+        return await self._open_tcp(session_factory, b'direct-tcpip',
+                                    host, port, orig_host, orig_port)
 
     async def accept(self, session_factory: SSHTCPSessionFactory[AnyStr],
                      host: str, port: int, orig_host: str,
                      orig_port: int) -> SSHTCPSession[AnyStr]:
         """Create a new forwarded TCP session"""
 
-        return (await self._open_tcp(session_factory, b'forwarded-tcpip',
-                                     host, port, orig_host, orig_port))
+        return await self._open_tcp(session_factory, b'forwarded-tcpip',
+                                    host, port, orig_host, orig_port)
 
     def set_inbound_peer_names(self, dest_host: str, dest_port: int,
                                orig_host: str, orig_port: int) -> None:

asyncssh/connection.py

@@ -3236,9 +3236,8 @@ async def tunnel_connection(
                     raise ChannelOpenError(OPEN_ADMINISTRATIVELY_PROHIBITED,
                                            'Connection forwarding denied')
 
-            return (await self.create_connection(session_factory,
-                                                 dest_host, dest_port,
-                                                 orig_host, orig_port))
+            return await self.create_connection(session_factory, dest_host,
+                                                dest_port, orig_host, orig_port)
 
         if (listen_host, listen_port) == (dest_host, dest_port):
             self.logger.info('Creating local TCP forwarder on %s',
@@ -5058,8 +5057,8 @@ async def create_ssh_connection(self, client_factory: _ClientFactory,
 
         """
 
-        return (await create_connection(client_factory, host, port,
-                                        tunnel=self, **kwargs)) # type: ignore
+        return await create_connection(client_factory, host, port,
+                                       tunnel=self, **kwargs) # type: ignore
 
     @async_context_manager
     async def connect_ssh(self, host: str, port: DefTuple[int] = (),
@@ -5327,8 +5326,7 @@ async def tunnel_connection(
                     raise ChannelOpenError(OPEN_ADMINISTRATIVELY_PROHIBITED,
                                            'Connection forwarding denied')
 
-            return (await self.create_unix_connection(session_factory,
-                                                      dest_path))
+            return await self.create_unix_connection(session_factory, dest_path)
 
         self.logger.info('Creating local TCP forwarder from %s to %s',
                          (listen_host, listen_port), dest_path)

asyncssh/sftp.py

@@ -5262,7 +5262,7 @@ async def exists(self, path: _SFTPPath) -> bool:
 
         """
 
-        return (await self._type(path)) != FILEXFER_TYPE_UNKNOWN
+        return await self._type(path) != FILEXFER_TYPE_UNKNOWN
 
     async def lexists(self, path: _SFTPPath) -> bool:
         """Return if the remote path exists, without following symbolic links
@@ -5275,7 +5275,7 @@ async def lexists(self, path: _SFTPPath) -> bool:
 
         """
 
-        return (await self._type(path, statfunc=self.lstat)) != \
+        return await self._type(path, statfunc=self.lstat) != \
             FILEXFER_TYPE_UNKNOWN
 
     async def getatime(self, path: _SFTPPath) -> Optional[float]:
@@ -5404,7 +5404,7 @@ async def isdir(self, path: _SFTPPath) -> bool:
 
         """
 
-        return (await self._type(path)) == FILEXFER_TYPE_DIRECTORY
+        return await self._type(path) == FILEXFER_TYPE_DIRECTORY
 
     async def isfile(self, path: _SFTPPath) -> bool:
         """Return if the remote path refers to a regular file
@@ -5417,7 +5417,7 @@ async def isfile(self, path: _SFTPPath) -> bool:
 
         """
 
-        return (await self._type(path)) == FILEXFER_TYPE_REGULAR
+        return await self._type(path) == FILEXFER_TYPE_REGULAR
 
     async def islink(self, path: _SFTPPath) -> bool:
         """Return if the remote path refers to a symbolic link
@@ -5430,7 +5430,7 @@ async def islink(self, path: _SFTPPath) -> bool:
 
         """
 
-        return (await self._type(path, statfunc=self.lstat)) == \
+        return await self._type(path, statfunc=self.lstat) == \
             FILEXFER_TYPE_SYMLINK
 
     async def remove(self, path: _SFTPPath) -> None:
@@ -8171,12 +8171,12 @@ async def _type(self, path: bytes) -> int:
     async def exists(self, path: bytes) -> bool:
         """Return if a path exists"""
 
-        return (await self._type(path)) != FILEXFER_TYPE_UNKNOWN
+        return await self._type(path) != FILEXFER_TYPE_UNKNOWN
 
     async def isdir(self, path: bytes) -> bool:
         """Return if the path refers to a directory"""
 
-        return (await self._type(path)) == FILEXFER_TYPE_DIRECTORY
+        return await self._type(path) == FILEXFER_TYPE_DIRECTORY
 
     def scandir(self, path: bytes) -> AsyncIterator[SFTPName]:
         """Return names and attributes of the files in a directory"""