(self)
| 301 | self.task_mqs[self._get_task_id(t)] = event_mq |
| 302 | |
| 303 | def need_keep_alive(self) -> bool: |
| 304 | # if callback thread is activated, then the session need to keep alive |
| 305 | return self.callback_thread is not None |
| 306 | |
| 307 | |
| 308 | class ScriptModeSession(ThreadBasedSession): |