(self)
| 449 | self._batch_feeder.put(input_data, self._coordinator) |
| 450 | |
| 451 | def finish(self): |
| 452 | self._metrics.put_metric( |
| 453 | 'fetcher_time', time.time() - self._start_time) |
| 454 | |
| 455 | |
| 456 | global_coordinator = GlobalCoordinator() |
nothing calls this directly
no test coverage detected