Merge pull request #183 from netzkolchose/transaction_pressure

reduce transaction pressure

Author: jerch

computedfields/resolver.py

@@ -476,17 +476,20 @@ def update_dependent(
         if updates:
             if not _is_recursive:
                 resolver_start.send(sender=self)
-            with transaction.atomic():  # FIXME: place transaction only once in tree descent
-                pks_updated: Dict[Type[Model], Set[Any]] = {}
+                with transaction.atomic():
+                    pks_updated: Dict[Type[Model], Set[Any]] = {}
+                    for queryset, fields in updates:
+                        _pks = self.bulk_updater(queryset, fields, return_pks=True, querysize=querysize)
+                        if _pks:
+                            pks_updated[queryset.model] = _pks
+                    if old:
+                        for model2, data in old.items():
+                            pks, fields = data
+                            queryset = model2.objects.filter(pk__in=pks-pks_updated.get(model2, set()))
+                            self.bulk_updater(queryset, fields, querysize=querysize)
+            else:
                 for queryset, fields in updates:
-                    _pks = self.bulk_updater(queryset, fields, return_pks=True, querysize=querysize)
-                    if _pks:
-                        pks_updated[queryset.model] = _pks
-                if old:
-                    for model2, data in old.items():
-                        pks, fields = data
-                        queryset = model2.objects.filter(pk__in=pks-pks_updated.get(model2, set()))
-                        self.bulk_updater(queryset, fields, querysize=querysize)
+                    self.bulk_updater(queryset, fields, return_pks=False, querysize=querysize)
             if not _is_recursive:
                 resolver_exit.send(sender=self)