baodan/tmp/trigger_full_flow.py

39 lines
1.2 KiB
Python

import json
from app import app
SESSION_ID = "39511ed73abe48208df44b7ab96af166"
with app.app_context():
from insurance.db.compat import db
from insurance.generation import task_service
from insurance.models.ppt_session import PptSession
session = db.session.get(PptSession, SESSION_ID)
files = json.loads(session.files_json or "[]")
session.status = "parsing"
session.workflow_step = "parsing"
session.parse_progress = 0
session.parse_message = "修复后端到端复测"
session.parse_error = None
session.extractions_json = "[]"
session.snapshot_ids_json = None
session.draft_revision = int(session.draft_revision or 1) + 1
db.session.commit()
result = task_service.create_task(
user_id=session.user_id,
artifact_type="ppt",
operation="parse",
workspace_id=SESSION_ID,
title="双方案真实文件复测",
input_snapshot={"files": files, "e2eReason": "parser-fix-verification"},
input_revision=session.draft_revision,
)
if result.get("code") == 0:
session.latest_task_id = result["data"]["id"]
db.session.commit()
print(json.dumps(result, ensure_ascii=False))