diff --git a/vllm/distributed/device_communicators/all2all.py b/vllm/distributed/device_communicators/all2all.py index c953fb9db3bc1..dc0db5a71e859 100644 --- a/vllm/distributed/device_communicators/all2all.py +++ b/vllm/distributed/device_communicators/all2all.py @@ -280,10 +280,4 @@ class DeepEPLLAll2AllManager(DeepEPAll2AllManagerBase): buffer_kwargs = self._make_all2all_kwargs(**kwargs) first_handle = self.handle_caches[0].get_or_create(buffer_kwargs, deep_ep.Buffer) second_handle = self.handle_caches[1].get_or_create(buffer_kwargs, deep_ep.Buffer) - return [first_handle, second_handle] - - def destroy(self): - for handle_cache in self.handle_caches: - with handle_cache._lock: - for _, handle in handle_cache._cache.items(): - handle.destroy() + return [first_handle, second_handle] \ No newline at end of file