(self)
| 350 | yield batchX, batchY |
| 351 | |
| 352 | def get(self): |
| 353 | # get data from the queue |
| 354 | dequeue = self.queue.dequeue() |
| 355 | if self.multi_inputs: |
| 356 | return dequeue[:-1], dequeue[-1] |
| 357 | else: |
| 358 | return dequeue[0], dequeue[1] |
| 359 | |
| 360 | def launch_threads(self, session, num_threads=1): |
| 361 | threads = [] |
no outgoing calls
no test coverage detected