Skip to content

Commit 29da72c

Browse files
committed
fix: re-set base node category
1 parent 701c2b3 commit 29da72c

File tree

1 file changed

+4
-0
lines changed
  • execution_engine/execution_graph

1 file changed

+4
-0
lines changed

execution_engine/execution_graph/graph.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -104,6 +104,10 @@ def traverse(
104104

105105
traverse(expr, category=category)
106106

107+
# make sure base node has still the correct category - it might have changed duing traversal if the base node
108+
# is used in an interval_criterion of a TemporalCount operator
109+
graph.nodes[base_node].update({"category": CohortCategory.BASE})
110+
107111
if hash(expr) != expr_hash:
108112
raise ValueError("Expression has been modified during traversal")
109113

0 commit comments

Comments
 (0)