(self)
| 1146 | return None |
| 1147 | |
| 1148 | def await_result(self): |
| 1149 | while self.is_running(): |
| 1150 | while True: |
| 1151 | chunk = self.pop_chunk() |
| 1152 | if chunk is not None: |
| 1153 | yield chunk |
| 1154 | else: |
| 1155 | break |
| 1156 | while True: |
| 1157 | chunk = self.pop_chunk() |
| 1158 | if chunk is None: |
| 1159 | break |
| 1160 | yield chunk |
| 1161 | |
| 1162 | def run_task_async(self, in_chat: bool = True, stream: bool = True, |
| 1163 | finish_step: ChatFinishStep = ChatFinishStep.GENERATE_CHART, return_img: bool = True): |
no test coverage detected