diff --git a/src/django_clickhouse/models.py b/src/django_clickhouse/models.py index 1c78f86..698eda2 100644 --- a/src/django_clickhouse/models.py +++ b/src/django_clickhouse/models.py @@ -175,7 +175,8 @@ class ClickHouseSyncModel(DjangoModel): def _on_commit(): for model_cls in cls.get_clickhouse_sync_models(): - storage.register_operations_wrapped(model_cls.get_import_key(), operation, *model_pks) + if model_cls.django_model == cls: + storage.register_operations_wrapped(model_cls.get_import_key(), operation, *model_pks) if len(model_pks) > 0: storage = cls.get_clickhouse_storage()