| 26 | self._imex_events.put(ffi_event.data2) |
| 27 | |
| 28 | def wait_progress(self, target_progress, progress_upper_limit=1000, progress_timeout=60): |
| 29 | while True: |
| 30 | ev = self._imex_events.get(timeout=progress_timeout) |
| 31 | if isinstance(ev, int) and ev >= target_progress: |
| 32 | assert ev <= progress_upper_limit, ( |
| 33 | str(ev) + " exceeded upper progress limit " + str(progress_upper_limit) |
| 34 | ) |
| 35 | return ev |
| 36 | if ev == 0: |
| 37 | return None |
| 38 | |
| 39 | def wait_finish(self, progress_timeout=60): |
| 40 | """Return list of written files, raise ValueError if ExportFailed.""" |