This commit is contained in:
Marsway 2026-01-13 10:08:50 +08:00
parent 1435653b0b
commit e3644d85ec
1 changed files with 11 additions and 11 deletions

View File

@ -169,17 +169,17 @@ def execute_job(self, job_id: str | None = None, snapshot_params: dict[str, Any]
) )
else: else:
if not snapshot: if not snapshot:
snapshot = snapshot_params or { snapshot = snapshot_params or {
"job_id": job_id, "job_id": job_id,
"handler_path": handler_path if "handler_path" in locals() else "", "handler_path": handler_path if "handler_path" in locals() else "",
"public_cfg": public_cfg if "public_cfg" in locals() else {}, "public_cfg": public_cfg if "public_cfg" in locals() else {},
"secret_cfg": secret_token if "secret_token" in locals() else "", "secret_cfg": secret_token if "secret_token" in locals() else "",
"meta": { "meta": {
"trigger": "celery", "trigger": "celery",
"celery_task_id": celery_task_id, "celery_task_id": celery_task_id,
"started_at": started_at.isoformat(), "started_at": started_at.isoformat(),
}, },
} }
crud.create_job_log( crud.create_job_log(
session, session,
job_id=str(job_id or ""), job_id=str(job_id or ""),