()
| 413 | |
| 414 | |
| 415 | def test_external_source_with_iter(): |
| 416 | for attempt in range(10): |
| 417 | pipe = Pipeline(1, 3, 0) |
| 418 | |
| 419 | pipe.set_outputs( |
| 420 | fn.external_source( |
| 421 | lambda i: [make_array([attempt * 100 + i * 10 + 1.5], dtype=datapy.float32)] |
| 422 | ) |
| 423 | ) |
| 424 | |
| 425 | for i in range(10): |
| 426 | check_output(pipe.run(), [np.array([attempt * 100 + i * 10 + 1.5], dtype=np.float32)]) |
| 427 | |
| 428 | |
| 429 | def test_external_source_with_sample_info(): |
nothing calls this directly
no test coverage detected