Skip to content

Commit cb5068c

Browse files
committed
Fix linter errors.
1 parent 5e0d5c2 commit cb5068c

File tree

3 files changed

+22
-12
lines changed

3 files changed

+22
-12
lines changed

tests/test_asyncio/test_pubsub.py

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1048,9 +1048,11 @@ async def get_msg():
10481048
assert msg is not None
10491049
# timeout waiting for another message which never arrives
10501050
assert pubsub.connection.is_connected
1051-
with patch("redis._parsers._AsyncRESP2Parser.read_response") as mock1, patch(
1052-
"redis._parsers._AsyncHiredisParser.read_response"
1053-
) as mock2, patch("redis._parsers._AsyncRESP3Parser.read_response") as mock3:
1051+
with (
1052+
patch("redis._parsers._AsyncRESP2Parser.read_response") as mock1,
1053+
patch("redis._parsers._AsyncHiredisParser.read_response") as mock2,
1054+
patch("redis._parsers._AsyncRESP3Parser.read_response") as mock3,
1055+
):
10541056
mock1.side_effect = BaseException("boom")
10551057
mock2.side_effect = BaseException("boom")
10561058
mock3.side_effect = BaseException("boom")

tests/test_cluster_transaction.py

Lines changed: 12 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -124,9 +124,12 @@ def test_retry_transaction_during_unfinished_slot_migration(self, r):
124124
slot = r.keyslot(key)
125125
node_migrating, node_importing = _find_source_and_target_node_for_slot(r, slot)
126126

127-
with patch.object(Redis, "parse_response") as parse_response, patch.object(
128-
NodesManager, "_update_moved_slots"
129-
) as manager_update_moved_slots:
127+
with (
128+
patch.object(Redis, "parse_response") as parse_response,
129+
patch.object(
130+
NodesManager, "_update_moved_slots"
131+
) as manager_update_moved_slots,
132+
):
130133

131134
def ask_redirect_effect(connection, *args, **options):
132135
if "MULTI" in args:
@@ -161,9 +164,12 @@ def test_retry_transaction_during_slot_migration_successful(self, r):
161164
slot = r.keyslot(key)
162165
node_migrating, node_importing = _find_source_and_target_node_for_slot(r, slot)
163166

164-
with patch.object(Redis, "parse_response") as parse_response, patch.object(
165-
NodesManager, "_update_moved_slots"
166-
) as manager_update_moved_slots:
167+
with (
168+
patch.object(Redis, "parse_response") as parse_response,
169+
patch.object(
170+
NodesManager, "_update_moved_slots"
171+
) as manager_update_moved_slots,
172+
):
167173

168174
def ask_redirect_effect(conn, *args, **options):
169175
# first call should go here, we trigger an AskError

tests/test_pubsub.py

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1138,9 +1138,11 @@ def get_msg():
11381138
assert msg is not None
11391139
# timeout waiting for another message which never arrives
11401140
assert is_connected()
1141-
with patch("redis._parsers._RESP2Parser.read_response") as mock1, patch(
1142-
"redis._parsers._HiredisParser.read_response"
1143-
) as mock2, patch("redis._parsers._RESP3Parser.read_response") as mock3:
1141+
with (
1142+
patch("redis._parsers._RESP2Parser.read_response") as mock1,
1143+
patch("redis._parsers._HiredisParser.read_response") as mock2,
1144+
patch("redis._parsers._RESP3Parser.read_response") as mock3,
1145+
):
11441146
mock1.side_effect = BaseException("boom")
11451147
mock2.side_effect = BaseException("boom")
11461148
mock3.side_effect = BaseException("boom")

0 commit comments

Comments
 (0)