Skip to content

Commit 5d2058b

Browse files
Apply ruff/pyupgrade rule UP020
UP020 Use builtin `open`
1 parent 7aee410 commit 5d2058b

File tree

1 file changed

+6
-7
lines changed

1 file changed

+6
-7
lines changed

tests/test_pipes.py

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,4 @@
11
import asyncio
2-
import io
32
import os
43
import socket
54

@@ -74,7 +73,7 @@ def test_read_pipe(self):
7473
proto = MyReadPipeProto(loop=self.loop)
7574

7675
rpipe, wpipe = os.pipe()
77-
pipeobj = io.open(rpipe, 'rb', 1024)
76+
pipeobj = open(rpipe, 'rb', 1024)
7877

7978
async def connect():
8079
t, p = await self.loop.connect_read_pipe(
@@ -106,7 +105,7 @@ def test_read_pty_output(self):
106105
proto = MyReadPipeProto(loop=self.loop)
107106

108107
master, slave = os.openpty()
109-
master_read_obj = io.open(master, 'rb', 0)
108+
master_read_obj = open(master, 'rb', 0)
110109

111110
async def connect():
112111
t, p = await self.loop.connect_read_pipe(
@@ -142,7 +141,7 @@ async def connect():
142141
def test_write_pipe(self):
143142
rpipe, wpipe = os.pipe()
144143
os.set_blocking(rpipe, False)
145-
pipeobj = io.open(wpipe, 'wb', 1024)
144+
pipeobj = open(wpipe, 'wb', 1024)
146145

147146
proto = MyWritePipeProto(loop=self.loop)
148147
connect = self.loop.connect_write_pipe(lambda: proto, pipeobj)
@@ -185,7 +184,7 @@ def test_write_pipe_disconnect_on_close(self):
185184
rsock, wsock = socket.socketpair()
186185
rsock.setblocking(False)
187186

188-
pipeobj = io.open(wsock.detach(), 'wb', 1024)
187+
pipeobj = open(wsock.detach(), 'wb', 1024)
189188

190189
proto = MyWritePipeProto(loop=self.loop)
191190
connect = self.loop.connect_write_pipe(lambda: proto, pipeobj)
@@ -207,7 +206,7 @@ def test_write_pty(self):
207206
master, slave = os.openpty()
208207
os.set_blocking(master, False)
209208

210-
slave_write_obj = io.open(slave, 'wb', 0)
209+
slave_write_obj = open(slave, 'wb', 0)
211210

212211
proto = MyWritePipeProto(loop=self.loop)
213212
connect = self.loop.connect_write_pipe(lambda: proto, slave_write_obj)
@@ -250,7 +249,7 @@ def reader(data):
250249

251250
def test_write_buffer_full(self):
252251
rpipe, wpipe = os.pipe()
253-
pipeobj = io.open(wpipe, 'wb', 1024)
252+
pipeobj = open(wpipe, 'wb', 1024)
254253

255254
proto = MyWritePipeProto(loop=self.loop)
256255
connect = self.loop.connect_write_pipe(lambda: proto, pipeobj)

0 commit comments

Comments
 (0)