diff --git a/tests/v1/kv_connector/unit/test_moriio_connector.py b/tests/v1/kv_connector/unit/test_moriio_connector.py index 1cc6988635d8..1eca4964fd6c 100644 --- a/tests/v1/kv_connector/unit/test_moriio_connector.py +++ b/tests/v1/kv_connector/unit/test_moriio_connector.py @@ -17,6 +17,7 @@ ModelConfig, SchedulerConfig, VllmConfig, + set_current_vllm_config, ) from vllm.distributed.kv_transfer.kv_connector.v1.moriio.moriio_common import ( MoRIIOAgentMetadata, @@ -433,10 +434,11 @@ def test_register_kv_caches(mock_parallel_groups): } ) - connector = MoRIIOConnector(vllm_config, KVConnectorRole.WORKER) - connector.connector_worker = FakeMorIIOConnectorWorker( - vllm_config, connector.engine_id, hand_shake_latency=0 - ) + with set_current_vllm_config(vllm_config): + connector = MoRIIOConnector(vllm_config, KVConnectorRole.WORKER) + connector.connector_worker = FakeMorIIOConnectorWorker( + vllm_config, connector.engine_id, hand_shake_latency=0 + ) from mori.io import ( MemoryDesc, @@ -523,7 +525,8 @@ def test_moriio_handshake_returns_metadata(mock_parallel_groups): "handshake_port": handshake_port, } ) - connector = MoRIIOConnector(vllm_config, KVConnectorRole.WORKER) + with set_current_vllm_config(vllm_config): + connector = MoRIIOConnector(vllm_config, KVConnectorRole.WORKER) # Execute register_kv_caches connector.register_kv_caches(kv_caches)