Skip to content

Commit 0dff1e4

Browse files
committed
Fix bugs
1 parent 1b5a635 commit 0dff1e4

File tree

2 files changed

+8
-5
lines changed

2 files changed

+8
-5
lines changed

python/paddle/fluid/layers/io.py

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@
2121

2222
__all__ = [
2323
'data', 'BlockGuardServ', 'ListenAndServ', 'Send', 'open_recordio_file',
24-
'open_files', 'read_file', 'shuffle', 'double_buffer'
24+
'open_files', 'read_file', 'shuffle', 'batch', 'double_buffer'
2525
]
2626

2727

@@ -469,6 +469,11 @@ def shuffle(reader, buffer_size):
469469
'create_shuffle_reader', reader, {'buffer_size': int(buffer_size)})
470470

471471

472+
def batch(reader, batch_size):
473+
return __create_unshared_decorated_reader__(
474+
'create_batch_reader', reader, {'batch_size': int(batch_size)})
475+
476+
472477
def double_buffer(reader, place=None):
473478
attrs = dict()
474479
if place is not None:

python/paddle/fluid/tests/unittests/test_multi_pass_reader.py

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -43,9 +43,8 @@ def test_main(self):
4343
filename='./mnist.recordio',
4444
shapes=[(-1, 784), (-1, 1)],
4545
lod_levels=[0, 0],
46-
dtypes=['float32', 'int64'])
47-
data_file = fluid.layers.io.multi_pass(
48-
reader=data_file, pass_num=self.pass_num)
46+
dtypes=['float32', 'int64'],
47+
pass_num=self.pass_num)
4948
img, label = fluid.layers.read_file(data_file)
5049

5150
if fluid.core.is_compiled_with_cuda():
@@ -65,5 +64,4 @@ def test_main(self):
6564
break
6665
batch_count += 1
6766
self.assertLessEqual(img_val.shape[0], self.batch_size)
68-
data_file.reset()
6967
self.assertEqual(batch_count, self.num_batch * self.pass_num)

0 commit comments

Comments
 (0)