(self)
| 185 | self.idx = idx |
| 186 | |
| 187 | def run(self): |
| 188 | enable_death_signal(_warn=self.idx == 0) |
| 189 | # reset all ds so each process will produce different data |
| 190 | self.ds.reset_state() |
| 191 | while True: |
| 192 | for dp in self.ds: |
| 193 | self.queue.put(dp) |
| 194 | |
| 195 | def __init__(self, ds, num_prefetch, num_proc): |
| 196 | """ |
nothing calls this directly
no test coverage detected