diff --git a/src/django_clickhouse/clickhouse_models.py b/src/django_clickhouse/clickhouse_models.py index 03d9675..3848973 100644 --- a/src/django_clickhouse/clickhouse_models.py +++ b/src/django_clickhouse/clickhouse_models.py @@ -183,7 +183,7 @@ class ClickHouseModel(with_metaclass(ClickHouseModelMeta, InfiModel)): :return: """ if batch: - cls.get_database(for_write=True).insert(batch) + cls.get_database(for_write=True).insert(batch, batch_size=len(batch)) @classmethod def sync_batch_from_storage(cls):