请问下机器学习PAI ，这个错误怎么办？

assert not is_closed, 'sync_que is closed'
AssertionError: sync_que is closed
easy_rec version: 0.7.5
Usage: easy_rec.help()
请问下机器学习PAI ，这个错误怎么办？执行的scripts/train_2gpu.sh

展开

收起

真的很搞笑 2023-10-29 20:16:59 80 0

2 条回答

写回答

取消提交回答

sunrr

这个错误信息表明，你的程序在尝试关闭一个已经关闭的队列。这可能是因为你的程序在启动时遇到了一些问题，导致队列在不应该被关闭的时候被关闭了。

解决这个问题的一种方法是在你的代码中添加一些错误处理代码，以便在出现这种情况时能够正确地处理。例如，你可以添加一些代码来检查队列的状态，并在队列已经被关闭时跳过相应的操作。

此外，你也可以尝试重新启动你的程序，并确保所有必要的资源都已经准备好。如果你的程序在启动时仍然遇到问题，你可能需要查看你的代码和配置，以确定问题的根源。

2023-10-30 11:38:37

赞同展开评论打赏
小周sir

面对过去，不要迷离；面对未来，不必彷徨；活在今天，你只要把自己完全展示给别人看。
此错误信息表明 sync_que 对象已被关闭，因此无法继续使用。这可能是由于 sync_que 对象在被关闭后仍试图访问它所致。通常，在使用完对象后，应该将其关闭以释放资源。关闭 sync_que 对象的正确方式是在完成所有工作后调用它的 close() 方法。
如果您使用的是 EasyRec v0.7.5，则可以尝试修改 train_2gpu.sh 脚本中的代码，以确保在不再需要 sync_que 对象后将其关闭。下面是一个示例：
```
with open("my_file.txt") as file:
    lines = file.readlines()

for line in lines:
    # do something with line
```
在上面的示例中，当 with 语句结束时，file 对象会自动关闭。这意味着您无需手动调用 file.close() 来关闭文件。
同样地，在 EasyRec 中，您可以使用类似的结构来确保 sync_que 对象在完成所有工作后被正确关闭。例如：
```
from queue import Queue

def my_function(sync_que):
    for _ in range(100):
        item = sync_que.get()
        # do something with item

if __name__ == "__main__":
    sync_que = Queue()
    # fill the queue with items

    try:
        with sync_que:
            my_function(sync_que)
    finally:
        sync_que.close()
```
在上面的示例中，无论 my_function 是否抛出异常，sync_que 都会在最后关闭。
2023-10-29 22:50:13

赞同展开评论打赏