(self, occurrence, block=True)
| 302 | log.info("{0}", message) |
| 303 | |
| 304 | def _record(self, occurrence, block=True): |
| 305 | assert isinstance(occurrence, Occurrence) |
| 306 | assert occurrence.timeline is None |
| 307 | assert occurrence.timestamp is None |
| 308 | assert ( |
| 309 | not self.is_final |
| 310 | ), "Trying to record a new occurrence in a finalized timeline" |
| 311 | |
| 312 | self._record_queue.put(occurrence, block=block) |
| 313 | if block: |
| 314 | self._record_queue.join() |
| 315 | |
| 316 | return occurrence |
| 317 | |
| 318 | def _recorder_worker(self): |
| 319 | while True: |
no test coverage detected