1.Add template deletion function​

2.Celery node deletion (admin only, offline status)

Author: zhanglongbin

data_server/algo_templates/mapper/algo_template_mapper.py

@@ -104,7 +104,8 @@ def delete_template_by_id(db: Session, template_id: int, user_id: str) -> bool:
 
     template = db.query(AlgoTemplate).filter(
         AlgoTemplate.id == template_id,
-        AlgoTemplate.user_id == user_id
+        AlgoTemplate.user_id == user_id,
+        AlgoTemplate.buildin == False
     ).first()
 
     if not template:

data_server/api/endpoints/celery_server.py

@@ -6,7 +6,7 @@
 from loguru import logger
 from data_server.database.session import get_sync_session
 from data_server.schemas.responses import response_success, response_fail
-from data_celery.redis_tools.tools import get_celery_server_list
+from data_celery.redis_tools.tools import get_celery_server_list, del_celery_server_list
 from data_server.database.session import get_celery_worker_redis_db,get_celery_info_details_key
 from data_celery.utils import get_timestamp
 
@@ -56,3 +56,27 @@ async def get_celery_server_list_api(isadmin: Annotated[bool | None, Header(alia
         return response_fail(msg="获取Celery服务器列表失败")
 
 
+@router.delete("/delete_celery_worker/{worker_name}", response_model=dict)
+async def delete_celery_worker_api(worker_name: str, isadmin: Annotated[bool | None, Header(alias="isadmin")] = None):
+    try:
+        if isadmin is None or isadmin == False:
+            return response_fail(msg="Only the admin can delete the Worker")
+
+        worker_name = worker_name.strip()
+
+        server_list = get_celery_server_list()
+        if worker_name not in server_list:
+            return response_fail(msg=f"Worker '{worker_name}' it_doesn_t_exist")
+
+        del_celery_server_list(worker_name)
+
+        celery_redis = get_celery_worker_redis_db()
+        celery_info_details_key = get_celery_info_details_key(worker_name)
+        celery_redis.delete(celery_info_details_key)
+
+        logger.info(f"the_administrator_manually_deletes_the_worker: {worker_name}")
+        return response_success(msg=f"successfully_deleted_worker: {worker_name}")
+    except Exception as e:
+        logger.error(f"delete_celery_worker error: {e}")
+        return response_fail(msg=f"failed_to_delete_the_worker: {str(e)}")
+