From d932036a96b50c434b0fa903e830a84aa735b719 Mon Sep 17 00:00:00 2001 From: fengzx33 Date: Tue, 2 Jul 2024 16:20:12 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E5=BA=94=E5=AF=B9sysak=E8=AF=8A?= =?UTF-8?q?=E6=96=AD=E8=BF=87=E7=A8=8B=E4=B8=AD=E4=BC=9A=E4=BA=A7=E7=94=9F?= =?UTF-8?q?=E6=96=87=E4=BB=B6=E9=9C=80=E8=A6=81post=E8=84=9A=E6=9C=AC?= =?UTF-8?q?=E5=A4=84=E7=90=86=E5=9C=BA=E6=99=AF=EF=BC=8C=E4=BD=BF=E7=94=A8?= =?UTF-8?q?task=5Fid=E5=81=9A=E4=B8=BA=E6=96=87=E4=BB=B6=E5=94=AF=E4=B8=80?= =?UTF-8?q?=E6=A0=87=E8=AF=86=EF=BC=8C=E6=96=B9=E4=BE=BFpre=E8=84=9A?= =?UTF-8?q?=E6=9C=AC=E5=8F=8Apost=E8=84=9A=E6=9C=AC=E5=A4=84=E7=90=86?= =?UTF-8?q?=EF=BC=8C=E4=B9=9F=E6=96=B9=E4=BE=BF=E5=90=8E=E7=BB=AD=E5=AF=B9?= =?UTF-8?q?=E6=96=87=E4=BB=B6=E8=BF=9B=E8=A1=8C=E6=A3=80=E7=B4=A2=E5=8F=8A?= =?UTF-8?q?=E4=B8=8B=E8=BD=BD=E7=AD=89=E6=93=8D=E4=BD=9C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- sysom_server/sysom_diagnosis/apps/task/helper.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/sysom_server/sysom_diagnosis/apps/task/helper.py b/sysom_server/sysom_diagnosis/apps/task/helper.py index c896b49f..81d2ee32 100644 --- a/sysom_server/sysom_diagnosis/apps/task/helper.py +++ b/sysom_server/sysom_diagnosis/apps/task/helper.py @@ -203,6 +203,7 @@ class DiagnosisHelper: if not os.path.exists(service_path): raise Exception("Can not find script file, please check service name") try: + params["task_id"] = instance.task_id resp = await DiagnosisHelper.run_subprocess_async( [service_path, json.dumps(params)] ) @@ -272,6 +273,7 @@ class DiagnosisHelper: return None # 3. Use PreProcessor to convert params to diagnosis jobs + params["task_id"] = instance.task_id diagnosis_task = pre_processor.get_diagnosis_cmds(params) if diagnosis_task is None or len(diagnosis_task.jobs) == 0: raise Exception(f"Pre-processor not return any diagnosis job") -- Gitee