From 134e31a5bbdd91ba82cc4cd10799093fe18bb371 Mon Sep 17 00:00:00 2001
From: "mingsheng.li" <mingsheng.li@gaiamesh.com>
Date: Fri, 1 Aug 2025 12:09:08 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8Dbatch=20size=E6=98=AF?=
 =?UTF-8?q?=E5=AD=97=E7=AC=A6=E4=B8=B2=E7=9A=84=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/pipelines/dbf_to_postgres_ctllog.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/pipelines/dbf_to_postgres_ctllog.py b/src/pipelines/dbf_to_postgres_ctllog.py
index 9b209f1..547e66e 100644
--- a/src/pipelines/dbf_to_postgres_ctllog.py
+++ b/src/pipelines/dbf_to_postgres_ctllog.py
@@ -32,7 +32,7 @@ class DbfToPostgresCtllogPipeline(BasePipeline):
 
         self.db = None
         self.group_cache = {}
-        self.batch_size = os.getenv('BATCH_SIZE', 1000)
+        self.batch_size = int(os.getenv('BATCH_SIZE', 1000))
         self.batch_data = []
         self.processed_records = 0
         self.current_date = None  # 当前处理的日期