(self, data_input_coordinator)
| 192 | utils.ResetBlobs(self._scratch_status.values()) |
| 193 | |
| 194 | def _get(self, data_input_coordinator): |
| 195 | start_time = time.time() |
| 196 | last_warning = time.time() |
| 197 | while data_input_coordinator.is_active(): |
| 198 | try: |
| 199 | return self._internal_queue.get(block=True, timeout=0.5) |
| 200 | except Queue.Empty: |
| 201 | if time.time() - last_warning > 10.0: |
| 202 | log.warning("** Data input is slow: (still) no data in {} secs.".format( |
| 203 | time.time() - start_time)) |
| 204 | last_warning = time.time() |
| 205 | continue |
| 206 | return None |
| 207 | |
| 208 | def _validate_chunk(self, chunk): |
| 209 | if chunk is None: |
no test coverage detected