(pipe1, pipe2, max_err)
| 215 | |
| 216 | |
| 217 | def compare(pipe1, pipe2, max_err): |
| 218 | epoch_size = pipe1.epoch_size("Reader") |
| 219 | batch_size = pipe1.max_batch_size |
| 220 | niter = (epoch_size + batch_size - 1) // batch_size |
| 221 | compare_pipelines(pipe1, pipe2, batch_size, niter, max_allowed_error=max_err) |
| 222 | |
| 223 | |
| 224 | io_types = [ |
no test coverage detected