From e3644d85ec532b31e06163e1a155ace85cac02c1 Mon Sep 17 00:00:00 2001 From: Marsway Date: Tue, 13 Jan 2026 10:08:50 +0800 Subject: [PATCH] update --- app/tasks/execute.py | 22 +++++++++++----------- 1 file changed, 11 insertions(+), 11 deletions(-) diff --git a/app/tasks/execute.py b/app/tasks/execute.py index 44217eb..17b12f4 100644 --- a/app/tasks/execute.py +++ b/app/tasks/execute.py @@ -169,17 +169,17 @@ def execute_job(self, job_id: str | None = None, snapshot_params: dict[str, Any] ) else: if not snapshot: - snapshot = snapshot_params or { - "job_id": job_id, - "handler_path": handler_path if "handler_path" in locals() else "", - "public_cfg": public_cfg if "public_cfg" in locals() else {}, - "secret_cfg": secret_token if "secret_token" in locals() else "", - "meta": { - "trigger": "celery", - "celery_task_id": celery_task_id, - "started_at": started_at.isoformat(), - }, - } + snapshot = snapshot_params or { + "job_id": job_id, + "handler_path": handler_path if "handler_path" in locals() else "", + "public_cfg": public_cfg if "public_cfg" in locals() else {}, + "secret_cfg": secret_token if "secret_token" in locals() else "", + "meta": { + "trigger": "celery", + "celery_task_id": celery_task_id, + "started_at": started_at.isoformat(), + }, + } crud.create_job_log( session, job_id=str(job_id or ""),