|
23 | 23 | from vllm.config import ParallelConfig, VllmConfig, set_current_vllm_config |
24 | 24 | from vllm.transformers_utils.detokenizer_utils import ( |
25 | 25 | convert_ids_list_to_tokens) |
26 | | -from vllm.utils import (CacheInfo, FlexibleArgumentParser, LRUCache, |
27 | | - MemorySnapshot, PlaceholderModule, StoreBoolean, |
28 | | - bind_kv_cache, common_broadcastable_dtype, |
29 | | - current_stream, deprecate_kwargs, get_open_port, |
30 | | - get_tcp_uri, is_lossless_cast, join_host_port, |
31 | | - make_zmq_path, make_zmq_socket, memory_profiling, |
32 | | - merge_async_iterators, sha256, split_host_port, |
33 | | - split_zmq_path, supports_kw, swap_dict_values) |
34 | 26 |
|
| 27 | +# isort: off |
| 28 | +from vllm.utils import ( |
| 29 | + CacheInfo, FlexibleArgumentParser, LRUCache, MemorySnapshot, |
| 30 | + PlaceholderModule, bind_kv_cache, common_broadcastable_dtype, |
| 31 | + current_stream, deprecate_kwargs, get_open_port, get_tcp_uri, |
| 32 | + is_lossless_cast, join_host_port, make_zmq_path, make_zmq_socket, |
| 33 | + memory_profiling, merge_async_iterators, sha256, split_host_port, |
| 34 | + split_zmq_path, supports_kw, swap_dict_values, unique_filepath) |
| 35 | +# isort: on |
35 | 36 | from ..utils import create_new_process_for_each_test, error_on_warning |
36 | 37 |
|
37 | 38 |
|
@@ -1032,3 +1033,15 @@ def test_load_config_file(tmp_path): |
1032 | 1033 | # Assert that the processed arguments match the expected output |
1033 | 1034 | assert processed_args == expected_args |
1034 | 1035 | os.remove(str(config_file_path)) |
| 1036 | + |
| 1037 | + |
| 1038 | +def test_unique_filepath(): |
| 1039 | + temp_dir = tempfile.mkdtemp() |
| 1040 | + path_fn = lambda i: Path(temp_dir) / f"file_{i}.txt" |
| 1041 | + paths = set() |
| 1042 | + for i in range(10): |
| 1043 | + path = unique_filepath(path_fn) |
| 1044 | + path.write_text("test") |
| 1045 | + paths.add(path) |
| 1046 | + assert len(paths) == 10 |
| 1047 | + assert len(list(Path(temp_dir).glob("*.txt"))) == 10 |
0 commit comments