Mark streaming as complete.
(self, interrupted: bool = False)
| 311 | return False |
| 312 | |
| 313 | def complete(self, interrupted: bool = False) -> None: |
| 314 | """Mark streaming as complete.""" |
| 315 | self.end_time = time.time() |
| 316 | self.interrupted = interrupted |
| 317 | if interrupted: |
| 318 | self.phase = StreamingPhase.INTERRUPTED |
| 319 | else: |
| 320 | self.phase = StreamingPhase.COMPLETED |
| 321 | |
| 322 | def mark_error(self) -> None: |
| 323 | """Mark streaming as errored.""" |
no outgoing calls