diff --git a/pipeline_bidding/bid_flow.py b/pipeline_bidding/bid_flow.py index b3e395a..705bb04 100644 --- a/pipeline_bidding/bid_flow.py +++ b/pipeline_bidding/bid_flow.py @@ -159,11 +159,12 @@ async def _dim_qc_improvements(sor, project_id, dim): async def _open_qc_type_tasks(sor, project_id, qc_type): """某类型在办 QC 审核任务数(params.qc_types 含该类型)。""" + kw = '%"qc_types": ["' + qc_type + '"]%' # 拼接构造:SQL 里 % 是 LIKE 通配符,不能用 % 格式化 recs = await sor.sqlExe( "SELECT COUNT(*) AS c FROM pipeline_tasks WHERE tenant_id=${p}$ " "AND pipeline_id='role_task' AND role=${r}$ AND state IN " "('submitted','running','review','qc_review') AND params LIKE ${kw}$", - {"p": project_id, "r": R_QC, "kw": '%"qc_types": ["%s"]%' % qc_type}) + {"p": project_id, "r": R_QC, "kw": kw}) await sor.sqlExe("COMMIT", {}) return to_int(getattr(recs[0], "c", 0) if recs else 0)