+ add missing finish method for file_wrapper

HYLcool · HYLcool · commit ec7f7c6ed8b4 · 2025-06-17T19:44:35.000+08:00
diff --git a/trinity/buffer/ray_wrapper.py b/trinity/buffer/ray_wrapper.py
@@ -171,3 +171,6 @@ def read(self) -> List:
         raise NotImplementedError(
             "read() is not implemented for FileWrapper, please use QUEUE instead"
         )
+
+    def finish(self) -> None:
+        self.file.close()

Original file line number	Diff line number	Diff line change
`@@ -171,3 +171,6 @@ def read(self) -> List:`
`171`	`171`	`raise NotImplementedError(`
`172`	`172`	`"read() is not implemented for FileWrapper, please use QUEUE instead"`
`173`	`173`	`)`
	`174`	`+`
	`175`	`+ def finish(self) -> None:`
	`176`	`+ self.file.close()`