(
testcase_name, file_root, batch_size, ndim, dtype, device, fortran_order, file_filter="*.npy"
)
| 607 | |
| 608 | |
| 609 | def _testimpl_numpy_reader_roi_empty_axes( |
| 610 | testcase_name, file_root, batch_size, ndim, dtype, device, fortran_order, file_filter="*.npy" |
| 611 | ): |
| 612 | # testcase name used for visibility in the output logs |
| 613 | @pipeline_def(batch_size=batch_size, device_id=0, num_threads=8) |
| 614 | def pipe(): |
| 615 | data0 = fn.readers.numpy( |
| 616 | device=device, |
| 617 | file_root=file_root, |
| 618 | file_filter=file_filter, |
| 619 | shard_id=0, |
| 620 | num_shards=1, |
| 621 | cache_header_information=False, |
| 622 | seed=1234, |
| 623 | ) |
| 624 | data1 = fn.readers.numpy( |
| 625 | device=device, |
| 626 | file_root=file_root, |
| 627 | file_filter=file_filter, |
| 628 | roi_start=[], |
| 629 | roi_end=[], |
| 630 | roi_axes=[], |
| 631 | shard_id=0, |
| 632 | num_shards=1, |
| 633 | cache_header_information=False, |
| 634 | seed=1234, |
| 635 | ) |
| 636 | return data0, data1 |
| 637 | |
| 638 | p = pipe() |
| 639 | try: |
| 640 | data0, data1 = p.run() |
| 641 | finally: |
| 642 | del p |
| 643 | for i in range(batch_size): |
| 644 | arr = to_array(data0[i]) |
| 645 | roi_arr = to_array(data1[i]) |
| 646 | assert_array_equal(arr, roi_arr) |
| 647 | |
| 648 | |
| 649 | def _testimpl_numpy_reader_roi_empty_range( |
no test coverage detected