Skip to content

Commit

Permalink
more windows hacks
Browse files Browse the repository at this point in the history
  • Loading branch information
RonnyPfannschmidt committed Apr 14, 2024
1 parent 081b443 commit b931ead
Show file tree
Hide file tree
Showing 2 changed files with 11 additions and 2 deletions.
10 changes: 9 additions & 1 deletion src/execnet/rsync.py
Original file line number Diff line number Diff line change
Expand Up @@ -138,7 +138,15 @@ def send(self, raises: bool = True) -> None:
self._paths: dict[str, int] = {}
self._to_send: dict[Channel, list[str]] = {}

# send modified file to clients
commands: dict[str | None, Callable] = {
None: self._end_of_channel,
"links": self._process_link,
"done": self._done,
"ack": self._ack,
"send": self._send_item,
"list_done": self._list_done,
}

while self._channels:
channel, req = self._receivequeue.get()
if req is None:
Expand Down
3 changes: 2 additions & 1 deletion testing/test_termination.py
Original file line number Diff line number Diff line change
Expand Up @@ -78,7 +78,8 @@ def test_termination_on_remote_channel_receive(
gw._group.terminate()
command = ["ps", "-p", str(pid)]
output = subprocess.run(command, capture_output=True, text=True, check=False)
assert str(pid) not in output.stdout, output
print(output.stdout)
assert str(pid) not in output.stdout


def test_close_initiating_remote_no_error(
Expand Down

0 comments on commit b931ead

Please sign in to comment.