Skip to content

Commit 0fc2511

Browse files
author
Łukasz Bobiński
committed
style: fix linter errors in test_default_request_handler.py
1 parent fd629cc commit 0fc2511

1 file changed

Lines changed: 4 additions & 1 deletion

File tree

tests/server/request_handlers/test_default_request_handler.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2733,6 +2733,7 @@ async def spy_register_producer(tid, task):
27332733
# Verify queue closed immediately
27342734
mock_queue.close.assert_awaited_with(immediate=True)
27352735

2736+
27362737
@pytest.mark.asyncio
27372738
async def test_on_message_send_consumer_error_cancels_producer_and_closes_queue():
27382739
"""Test that if the consumer raises an exception during blocking wait, the producer is cancelled."""
@@ -2769,7 +2770,9 @@ async def test_on_message_send_consumer_error_cancels_producer_and_closes_queue(
27692770

27702771
# Mock ResultAggregator to raise exception
27712772
mock_result_aggregator_instance = MagicMock(spec=ResultAggregator)
2772-
mock_result_aggregator_instance.consume_and_break_on_interrupt.side_effect = ValueError('Consumer failed!')
2773+
mock_result_aggregator_instance.consume_and_break_on_interrupt.side_effect = ValueError(
2774+
'Consumer failed!'
2775+
)
27732776

27742777
# Capture the producer task to verify cancellation
27752778
captured_producer_task = None

0 commit comments

Comments
 (0)