Execute pre-commit run in all files

Author: nicoddemus

src/execnet/gateway_base.py

@@ -596,7 +596,7 @@ class GatewayReceivedTerminate(Exception):
 
 def geterrortext(excinfo, format_exception=traceback.format_exception, sysex=sysex):
     try:
-        l = format_exception(*excinfo)
+        l = format_exception(*excinfo)  # noqa:E741
         errortext = "".join(l)
     except sysex:
         raise
@@ -633,6 +633,7 @@ class TimeoutError(IOError):
 
 class Channel:
     "Communication channel between two Python Interpreter execution points."
+
     RemoteError = RemoteError
     TimeoutError = TimeoutError
     _INTERNALWAKEUP = 1000
@@ -1543,7 +1544,7 @@ def _save_integral(self, i, short_op, long_op):
     def save_int(self, i):
         self._save_integral(i, opcode.INT, opcode.LONGINT)
 
-    def save_long(self, l):
+    def save_long(self, l):  # noqa:E741
         self._save_integral(l, opcode.LONG, opcode.LONGLONG)
 
     def save_float(self, flt):

src/execnet/gateway_io.py

@@ -3,7 +3,6 @@
 
 creates io instances used for gateway io
 """
-import os
 import shlex
 import sys
 
@@ -228,4 +227,4 @@ def control(data):
 
 
 if __name__ == "__channelexec__":
-    serve_proxy_io(channel)  # type: ignore[name-defined]
+    serve_proxy_io(channel)  # type: ignore[name-defined] # noqa:F821

src/execnet/rsync_remote.py

@@ -114,4 +114,4 @@ def receive_directory_structure(path, relcomponents):
 
 
 if __name__ == "__channelexec__":
-    serve_rsync(channel)  # type: ignore[name-defined]
+    serve_rsync(channel)  # type: ignore[name-defined]  # noqa:F821

src/execnet/script/shell.py

@@ -26,7 +26,7 @@ def clientside():
         while 1:
             r, w, e = select.select(inputlist, [], [])
             if sys.stdin in r:
-                line = raw_input()
+                line = raw_input()  # noqa:F821
                 sock.sendall(line + "\n")
             if sock in r:
                 line = sock.recv(4096)

testing/test_threadpool.py

@@ -1,5 +1,4 @@
 import os
-import sys
 
 import pytest
 from execnet.gateway_base import WorkerPool
@@ -61,7 +60,7 @@ def first():
 
 
 def test_waitfinish_on_reply(pool):
-    l = []
+    l = []  # noqa:E741
     reply = pool.spawn(lambda: l.append(1))
     reply.waitfinish()
     assert l == [1]