From 326b78ef3a195774fcbb6e0c63317ce667b27f73 Mon Sep 17 00:00:00 2001
From: root <root@64792e78fd4d>
Date: Sat, 6 Dec 2025 16:06:56 +0800
Subject: [PATCH] =?UTF-8?q?add=20workflow=20=E5=AE=A2=E6=88=B7=E4=BF=A1?=
 =?UTF-8?q?=E6=81=AF=E8=A1=A5=E5=85=A8=E3=80=90156,dev?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../【163】客户基础信息补全/account_complete_163.py           | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/dev/workflow/TK_Cust/account_info_complete/【163】客户基础信息补全/account_complete_163.py b/dev/workflow/TK_Cust/account_info_complete/【163】客户基础信息补全/account_complete_163.py
index c90bef9..5566ab0 100644
--- a/dev/workflow/TK_Cust/account_info_complete/【163】客户基础信息补全/account_complete_163.py
+++ b/dev/workflow/TK_Cust/account_info_complete/【163】客户基础信息补全/account_complete_163.py
@@ -329,7 +329,7 @@ def process_single_item(api_client, item_text, type, item_index, total_count):
 def main():
     """主函数"""
     # 配置并发数
-    MAX_WORKERS = 10  # 可调整为5或10
+    MAX_WORKERS = 3  # 可调整为5或10
     
     # 数据库配置
     db_config = {
@@ -361,7 +361,7 @@ def main():
 WITH numbered_names AS (
     SELECT 
         name,
-        (ROW_NUMBER() OVER (ORDER BY dw_account) - 1) /10 as batch_num
+        (ROW_NUMBER() OVER (ORDER BY dw_account) - 1) /5 as batch_num
    FROM p30_common.v_sql_cleaned_cn_d_account_info
   WHERE name NOT IN (
     SELECT "search"