(cls)
| 318 | |
| 319 | @classmethod |
| 320 | def get_current_task_id(cls): |
| 321 | task_id = super().get_current_task_id() |
| 322 | session = cls.get_current_session() |
| 323 | if task_id not in session.task_mqs: |
| 324 | session.register_thread(threading.current_thread()) |
| 325 | return task_id |
| 326 | |
| 327 | instance = None |
| 328 |
nothing calls this directly
no test coverage detected