(self, timeout=0.5)
| 211 | return instance |
| 212 | |
| 213 | def is_running(self, timeout=0.5): |
| 214 | try: |
| 215 | r = concurrent.futures.wait([self.future], timeout) |
| 216 | if len(r.not_done) > 0: |
| 217 | return True |
| 218 | else: |
| 219 | return False |
| 220 | except Exception as e: |
| 221 | return True |
| 222 | |
| 223 | def init_messages(self, session: Session): |
| 224 |
no outgoing calls
no test coverage detected