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 ""),