(self, logdir)
| 256 | self.assertRaises(StopIteration, lambda: next(rr)) |
| 257 | |
| 258 | def _csv_data(self, logdir): |
| 259 | # Create a small data file with 3 CSV records. |
| 260 | data_path = os.path.join(logdir, "data.csv") |
| 261 | with open(data_path, "w") as f: |
| 262 | f.write("1,2,3\n") |
| 263 | f.write("4,5,6\n") |
| 264 | f.write("7,8,9\n") |
| 265 | return data_path |
| 266 | |
| 267 | def testManagedEndOfInputOneQueue(self): |
| 268 | # Tests that the supervisor finishes without an error when using |
no test coverage detected