diff --git a/metricflow/dataflow/optimizer/predicate_pushdown_optimizer.py b/metricflow/dataflow/optimizer/predicate_pushdown_optimizer.py index 4fcf4666e7..841120460f 100644 --- a/metricflow/dataflow/optimizer/predicate_pushdown_optimizer.py +++ b/metricflow/dataflow/optimizer/predicate_pushdown_optimizer.py @@ -462,8 +462,7 @@ def visit_join_conversion_events_node(self, node: JoinConversionEventsNode) -> O def visit_join_to_custom_granularity_node( # noqa: D102 self, node: JoinToCustomGranularityNode ) -> OptimizeBranchResult: - self._log_visit_node_type(node) - return self._default_handler(node) + raise NotImplementedError def visit_join_on_entities_node(self, node: JoinOnEntitiesNode) -> OptimizeBranchResult: """Handles pushdown state propagation for the standard join node type.