graceful cleanup

Signed-off-by: zhihuiwan <15779896112@163.com>

Author: zhihuiwan

python/fate_flow/controller/task_controller.py

@@ -207,12 +207,15 @@ def kill_task(cls, task: Task):
         kill_status = False
         try:
             # kill task executor
-            backend_engine = build_engine(
-                task.f_engine_conf.get("computing_engine"),
-                task.f_is_deepspeed
-                )
-            if backend_engine:
-                backend_engine.kill(task)
+            try:
+                backend_engine = build_engine(
+                    task.f_engine_conf.get("computing_engine"),
+                    task.f_is_deepspeed
+                    )
+                if backend_engine:
+                    backend_engine.kill(task)
+            except Exception as e:
+                schedule_logger(task.f_job_id).exception(e)
             WorkerManager.kill_task_all_workers(task)
         except Exception as e:
             schedule_logger(task.f_job_id).exception(e)