Fix dataloader cleanup error with no workers (#18732)

Signed-off-by: Mohammed Yasin <32206511+Y-T-G@users.noreply.github.com>
This commit is contained in:
Mohammed Yasin 2025-01-17 19:18:49 +08:00 committed by GitHub
parent b1042c4da8
commit 309f5cafc1
No known key found for this signature in database
GPG key ID: B5690EEEBB952194

View file

@ -49,10 +49,11 @@ class InfiniteDataLoader(dataloader.DataLoader):
def __del__(self):
"""Ensure that workers are terminated."""
for w in self.iterator._workers: # force terminate
if w.is_alive():
w.terminate()
self.iterator._shutdown_workers() # cleanup
if hasattr(self.iterator, "_workers"):
for w in self.iterator._workers: # force terminate
if w.is_alive():
w.terminate()
self.iterator._shutdown_workers() # cleanup
def reset(self):
"""