| 137 | |
| 138 | |
| 139 | class _ExternalDataBatch: |
| 140 | def __init__(self, group, pipeline, data, batch_size): |
| 141 | self._group = group |
| 142 | self._pipepline = pipeline |
| 143 | self._data = data |
| 144 | self._batch_size = batch_size |
| 145 | |
| 146 | def feed(self): |
| 147 | self._group.feed(self._pipepline, self._data, self._batch_size) |
| 148 | |
| 149 | |
| 150 | class _ExternalSourceGroup(object): |
no outgoing calls
no test coverage detected