File tree Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -443,7 +443,7 @@ async def receive(self, channel):
443
443
else :
444
444
self .receive_buffer [message_channel ].put_nowait (message )
445
445
message = None
446
- except :
446
+ except Exception :
447
447
del self .receive_buffer [channel ]
448
448
raise
449
449
finally :
Original file line number Diff line number Diff line change @@ -382,19 +382,19 @@ async def test_connection_pool_pop():
382
382
383
383
# Emualte a disconnect and return it to the pool
384
384
conn .close ()
385
- assert conn .closed == True
385
+ assert conn .closed
386
386
connection_pool .push (conn )
387
387
388
388
# Ensure the closed connection is inside the pool
389
389
conn_map_values = list (connection_pool .conn_map .values ())
390
390
assert len (conn_map_values ) == 1
391
391
conns = conn_map_values [0 ]
392
392
assert len (conns ) == 1
393
- assert conns [0 ].closed == True
393
+ assert conns [0 ].closed
394
394
395
395
# Retrieve new connection
396
396
conn = await connection_pool .pop ()
397
- assert conn .closed == False
397
+ assert not conn .closed
398
398
399
399
400
400
@pytest .mark .asyncio
You can’t perform that action at this time.
0 commit comments