获取任务状态
(self, task_uuid: str)
| 221 | logger.warning(f"广播任务状态失败: {e}") |
| 222 | |
| 223 | def get_status(self, task_uuid: str) -> Optional[dict]: |
| 224 | """获取任务状态""" |
| 225 | return _task_status.get(task_uuid) |
| 226 | |
| 227 | def cleanup_task(self, task_uuid: str): |
| 228 | """清理任务数据""" |