Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions .pre-commit-config.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ repos:
hooks:
- id: check-yaml
- repo: https://github.com/astral-sh/ruff-pre-commit
rev: v0.12.12
rev: v0.13.0
hooks:
- id: ruff
args: [ --fix ]
Expand All @@ -26,7 +26,7 @@ repos:
args: ["--ignore", "D001"]

- repo: https://github.com/pre-commit/mirrors-mypy
rev: 'v1.17.1'
rev: 'v1.18.1'
hooks:
- id: mypy
additional_dependencies:
Expand Down
4 changes: 2 additions & 2 deletions src/execnet/gateway_base.py
Original file line number Diff line number Diff line change
Expand Up @@ -1007,7 +1007,7 @@ def _no_longer_opened(self, id: int) -> None:
except KeyError:
pass
try:
callback, endmarker, strconfig = self._callbacks.pop(id)
callback, endmarker, _strconfig = self._callbacks.pop(id)
except KeyError:
pass
else:
Expand Down Expand Up @@ -1037,7 +1037,7 @@ def _local_receive(self, id: int, data) -> None:
# executes in receiver thread
channel = self._channels.get(id)
try:
callback, endmarker, strconfig = self._callbacks[id]
callback, _endmarker, strconfig = self._callbacks[id]
except KeyError:
queue = channel._items if channel is not None else None
if queue is None:
Expand Down
2 changes: 1 addition & 1 deletion src/execnet/script/shell.py
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ def clientside() -> NoReturn:
inputlist = [sock, sys.stdin]
try:
while 1:
r, w, e = select.select(inputlist, [], [])
r, _w, _e = select.select(inputlist, [], [])
if sys.stdin in r:
line = input()
sock.sendall((line + "\n").encode())
Expand Down
2 changes: 1 addition & 1 deletion testing/test_gateway.py
Original file line number Diff line number Diff line change
Expand Up @@ -503,7 +503,7 @@ def test_popen_stderr_tracing(
monkeypatch.setenv("EXECNET_DEBUG", "2")
gw = makegateway("popen")
pid = gw.remote_exec("import os ; channel.send(os.getpid())").receive()
out, err = capfd.readouterr()
_out, err = capfd.readouterr()
worker_line = "[%s] creating workergateway" % pid
assert worker_line in err
gw.exit()
Expand Down
2 changes: 1 addition & 1 deletion testing/test_rsync.py
Original file line number Diff line number Diff line change
Expand Up @@ -142,7 +142,7 @@ def test_rsync_default_reporting(
rsync = RSync(source)
rsync.add_target(gw1, dirs.dest1)
rsync.send()
out, err = capsys.readouterr()
out, _err = capsys.readouterr()
assert out.find("hello") != -1

def test_rsync_non_verbose(
Expand Down
2 changes: 1 addition & 1 deletion testing/test_serializer.py
Original file line number Diff line number Diff line change
Expand Up @@ -155,7 +155,7 @@ def test_bool(dump, load) -> None:

def test_none(dump, load) -> None:
p = dump("None")
tp, s = load(p)
_tp, s = load(p)
assert s == "None"


Expand Down
4 changes: 2 additions & 2 deletions testing/test_termination.py
Original file line number Diff line number Diff line change
Expand Up @@ -102,7 +102,7 @@ def test_close_initiating_remote_no_error(
popen = subprocess.Popen(
[anypython, str(p), str(execnetdir)], stdout=None, stderr=subprocess.PIPE
)
out, err = popen.communicate()
_out, err = popen.communicate()
print(err)
errstr = err.decode("utf8")
lines = [x for x in errstr.splitlines() if "*sys-package" not in x]
Expand Down Expand Up @@ -151,6 +151,6 @@ def flush(self):
popen.stdout.readline()
reply = pool.spawn(popen.communicate)
reply.get(timeout=50)
out, err = capfd.readouterr()
_out, err = capfd.readouterr()
lines = [x for x in err.splitlines() if "*sys-package" not in x]
assert not lines or "Killed" in err
2 changes: 1 addition & 1 deletion testing/test_threadpool.py
Original file line number Diff line number Diff line change
Expand Up @@ -164,7 +164,7 @@ def wait_then_put() -> None:

pool.execmodel.start(wait_then_put)
assert pool.waitall()
out, err = capfd.readouterr()
_out, err = capfd.readouterr()
assert err == ""


Expand Down
Loading