Skip to content

Commit 9d780fc

Browse files
committed
fix per Emanuel
1 parent 616a418 commit 9d780fc

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

django_mongodb/aggregates.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
from django.db.models.aggregates import Aggregate, Count, StdDev, Variance
2-
from django.db.models.expressions import Case, Col, Value, When
2+
from django.db.models.expressions import Case, Value, When
33
from django.db.models.lookups import IsNull
44

55
from .query_utils import process_lhs
@@ -16,7 +16,7 @@ def aggregate(
1616
resolve_inner_expression=False,
1717
**extra_context, # noqa: ARG001
1818
):
19-
if self.filter and not isinstance(self.filter, Col):
19+
if self.filter:
2020
node = self.copy()
2121
node.filter = None
2222
source_expressions = node.get_source_expressions()

django_mongodb/compiler.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,7 @@ def _prepare_expressions_for_pipeline(self, expression, target, annotation_group
9191
rhs = sub_expr.as_mql(self, self.connection, resolve_inner_expression=True)
9292
group[alias] = {"$addToSet": rhs}
9393
replacing_expr = sub_expr.copy()
94-
replacing_expr.set_source_expressions([inner_column])
94+
replacing_expr.set_source_expressions([inner_column, None])
9595
else:
9696
group[alias] = sub_expr.as_mql(self, self.connection)
9797
replacing_expr = inner_column

0 commit comments

Comments
 (0)