[Fix]close #1569

2019-04-11 09:18:41 +08:00 · 2019-04-11 09:18:41 +08:00 · 219fbe2b5f
commit 219fbe2b5f
parent 1a79ba37db
1 changed files with 1 additions and 1 deletions
--- a/vnpy/app/csv_loader/engine.py
+++ b/vnpy/app/csv_loader/engine.py
@ -107,7 +107,7 @@ class CsvLoaderEngine(BaseEngine):

        # Insert into DB
        with DB.atomic():
-            for batch in chunked(db_bars, 500):
+            for batch in chunked(db_bars, 50):
                DbBarData.insert_many(batch).on_conflict_replace().execute()

        return start, end, count