提交 825fcd39 编写于 作者: Y yaoxuefeng6

fix ut

上级 32d2d3b5
...@@ -34,8 +34,5 @@ class MyDataset(fleet.MultiSlotDataGenerator): ...@@ -34,8 +34,5 @@ class MyDataset(fleet.MultiSlotDataGenerator):
if __name__ == "__main__": if __name__ == "__main__":
#start = time.clock()
d = MyDataset() d = MyDataset()
d.run_from_stdin() d.run_from_stdin()
#elapsed = (time.clock() - start)
#print("Time used:",elapsed)
...@@ -15,6 +15,7 @@ import unittest ...@@ -15,6 +15,7 @@ import unittest
import paddle.distributed.fleet as fleet import paddle.distributed.fleet as fleet
import os import os
import sys import sys
import platform
class MyMultiSlotDataGenerator(fleet.MultiSlotDataGenerator): class MyMultiSlotDataGenerator(fleet.MultiSlotDataGenerator):
...@@ -109,9 +110,11 @@ class TestMultiSlotStringDataGenerator(unittest.TestCase): ...@@ -109,9 +110,11 @@ class TestMultiSlotStringDataGenerator(unittest.TestCase):
class TestMultiSlotStringDataGenerator_2(unittest.TestCase): class TestMultiSlotStringDataGenerator_2(unittest.TestCase):
@unittest.skipIf(sys.platform == "win32",
"Windows does not support this pipe command")
def test_MyMultiSlotStringDataGenerator_stdin(self): def test_MyMultiSlotStringDataGenerator_stdin(self):
plats = platform.platform()
if 'Linux' not in plats:
print("skip pipecommand UT on MacOS/Win")
return
with open("test_queue_dataset_run_a.txt", "w") as f: with open("test_queue_dataset_run_a.txt", "w") as f:
data = "2 1 2\n" data = "2 1 2\n"
data += "2 6 2\n" data += "2 6 2\n"
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册