@@ -21,8 +21,9 @@ def fake_py_dlt_client_main_loop(client, callback, *args, **kwargs):
2121@contextmanager
2222def dlt_broker (pydlt_main_func = fake_py_dlt_client_main_loop , enable_dlt_time = True , enable_filter_set_ack = False ):
2323 """Initialize a fake DLTBroker"""
24- with patch ("dlt.dlt_broker_handlers.DLTMessageHandler._client_connect" ), patch (
25- "dlt.dlt_broker_handlers.py_dlt_client_main_loop" , side_effect = pydlt_main_func
24+ with (
25+ patch ("dlt.dlt_broker_handlers.DLTMessageHandler._client_connect" ),
26+ patch ("dlt.dlt_broker_handlers.py_dlt_client_main_loop" , side_effect = pydlt_main_func ),
2627 ):
2728 broker = DLTBroker ("42.42.42.42" , enable_dlt_time = enable_dlt_time , enable_filter_set_ack = enable_filter_set_ack )
2829 broker .msg_handler ._client = MagicMock ()
@@ -205,9 +206,10 @@ def test_add_context_with_ack_warning():
205206 """Test to send a filter-setting message but not received an ack"""
206207 queue = tqueue .Queue ()
207208
208- with patch ("dlt.dlt_broker.DLTBroker._recv_filter_set_ack" , return_value = False ) as ack_mock , patch .object (
209- logger , "warning"
210- ) as logger_mock :
209+ with (
210+ patch ("dlt.dlt_broker.DLTBroker._recv_filter_set_ack" , return_value = False ) as ack_mock ,
211+ patch .object (logger , "warning" ) as logger_mock ,
212+ ):
211213 with dlt_broker (enable_filter_set_ack = True ) as broker :
212214 ori_context_handler = broker .context_handler
213215 broker .context_handler = MagicMock ()
0 commit comments