fix deep ep ll teardown

Signed-off-by: Sage Moore <sage@neuralmagic.com>
This commit is contained in:
Sage Moore 2025-07-09 20:12:10 +00:00
parent 9b5913ed10
commit b53450e368

View File

@ -281,3 +281,9 @@ class DeepEPLLAll2AllManager(DeepEPAll2AllManagerBase):
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()