diff --git a/metricflow/test/snapshots/test_column_pruner.py/SqlQueryPlan/test_prune_distinct_select__after_pruning.sql b/metricflow/test/snapshots/test_column_pruner.py/SqlQueryPlan/test_prune_distinct_select__after_pruning.sql
new file mode 100644
index 0000000000..9acdadd458
--- /dev/null
+++ b/metricflow/test/snapshots/test_column_pruner.py/SqlQueryPlan/test_prune_distinct_select__after_pruning.sql
@@ -0,0 +1,10 @@
+-- test0
+SELECT
+  a.booking_value
+FROM (
+  -- test1
+  SELECT DISTINCT
+    a.booking_value
+    , a.bookings
+  FROM demo.fct_bookings a
+) b
diff --git a/metricflow/test/snapshots/test_column_pruner.py/SqlQueryPlan/test_prune_distinct_select__before_pruning.sql b/metricflow/test/snapshots/test_column_pruner.py/SqlQueryPlan/test_prune_distinct_select__before_pruning.sql
new file mode 100644
index 0000000000..9acdadd458
--- /dev/null
+++ b/metricflow/test/snapshots/test_column_pruner.py/SqlQueryPlan/test_prune_distinct_select__before_pruning.sql
@@ -0,0 +1,10 @@
+-- test0
+SELECT
+  a.booking_value
+FROM (
+  -- test1
+  SELECT DISTINCT
+    a.booking_value
+    , a.bookings
+  FROM demo.fct_bookings a
+) b
diff --git a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_compute_metrics_node__plan0.xml b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_compute_metrics_node__plan0.xml
index 76ef510cce..77ef9e9b24 100644
--- a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_compute_metrics_node__plan0.xml
+++ b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_compute_metrics_node__plan0.xml
@@ -16,6 +16,7 @@
         <!--    'column_alias': 'bookings'}                           -->
         <!-- from_source = SqlSelectStatementNode(node_id=ss_3) -->
         <!-- where = None -->
+        <!-- distinct = False -->
         <SqlSelectStatementNode>
             <!-- description = Aggregate Measures -->
             <!-- node_id = ss_3 -->
@@ -41,6 +42,7 @@
             <!--    'expr': SqlColumnReferenceExpression(node_id=cr_10),  -->
             <!--    'column_alias': 'listing__country_latest'}            -->
             <!-- where = None -->
+            <!-- distinct = False -->
             <SqlSelectStatementNode>
                 <!-- description = Join Standard Outputs -->
                 <!-- node_id = ss_2 -->
@@ -64,6 +66,7 @@
                 <!--    'join_type': SqlJoinType.LEFT_OUTER,                     -->
                 <!--    'on_condition': SqlComparisonExpression(node_id=cmp_0)}  -->
                 <!-- where = None -->
+                <!-- distinct = False -->
                 <SqlSelectStatementNode>
                     <!-- description =                -->
                     <!--   Pass Only Elements:        -->
@@ -79,6 +82,7 @@
                     <!--    'column_alias': 'bookings'}                          -->
                     <!-- from_source = SqlSelectStatementNode(node_id=ss_10001) -->
                     <!-- where = None -->
+                    <!-- distinct = False -->
                     <SqlSelectStatementNode>
                         <!-- description = Read Elements From Semantic Model 'bookings_source' -->
                         <!-- node_id = ss_10001 -->
@@ -436,6 +440,7 @@
                         <!--    'column_alias': 'booking__host'}                         -->
                         <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10001) -->
                         <!-- where = None -->
+                        <!-- distinct = False -->
                         <SqlTableFromClauseNode>
                             <!-- description = Read from ***************************.fct_bookings -->
                             <!-- node_id = tfc_10001 -->
@@ -458,6 +463,7 @@
                     <!--    'column_alias': 'country_latest'}                    -->
                     <!-- from_source = SqlSelectStatementNode(node_id=ss_10004) -->
                     <!-- where = None -->
+                    <!-- distinct = False -->
                     <SqlSelectStatementNode>
                         <!-- description = Read Elements From Semantic Model 'listings_latest' -->
                         <!-- node_id = ss_10004 -->
@@ -687,6 +693,7 @@
                         <!--    'column_alias': 'listing__user'}                         -->
                         <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10004) -->
                         <!-- where = None -->
+                        <!-- distinct = False -->
                         <SqlTableFromClauseNode>
                             <!-- description = Read from ***************************.dim_listings_latest -->
                             <!-- node_id = tfc_10004 -->
diff --git a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_compute_metrics_node_ratio_from_multiple_semantic_models__plan0.xml b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_compute_metrics_node_ratio_from_multiple_semantic_models__plan0.xml
index bd7bff1c0a..a20f2ab36a 100644
--- a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_compute_metrics_node_ratio_from_multiple_semantic_models__plan0.xml
+++ b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_compute_metrics_node_ratio_from_multiple_semantic_models__plan0.xml
@@ -16,6 +16,7 @@
         <!--    'column_alias': 'bookings_per_view'}                  -->
         <!-- from_source = SqlSelectStatementNode(node_id=ss_23) -->
         <!-- where = None -->
+        <!-- distinct = False -->
         <SqlSelectStatementNode>
             <!-- description = Combine Metrics -->
             <!-- node_id = ss_23 -->
@@ -43,6 +44,7 @@
             <!--    'join_type': SqlJoinType.INNER,                         -->
             <!--    'on_condition': SqlLogicalExpression(node_id=lo_4)}     -->
             <!-- where = None -->
+            <!-- distinct = False -->
             <SqlSelectStatementNode>
                 <!-- description = Compute Metrics via Expressions -->
                 <!-- node_id = ss_14 -->
@@ -60,6 +62,7 @@
                 <!--    'column_alias': 'bookings'}                            -->
                 <!-- from_source = SqlSelectStatementNode(node_id=ss_13) -->
                 <!-- where = None -->
+                <!-- distinct = False -->
                 <SqlSelectStatementNode>
                     <!-- description = Aggregate Measures -->
                     <!-- node_id = ss_13 -->
@@ -85,6 +88,7 @@
                     <!--    'expr': SqlColumnReferenceExpression(node_id=cr_628),  -->
                     <!--    'column_alias': 'listing__country_latest'}             -->
                     <!-- where = None -->
+                    <!-- distinct = False -->
                     <SqlSelectStatementNode>
                         <!-- description =                                           -->
                         <!--   Pass Only Elements:                                   -->
@@ -104,6 +108,7 @@
                         <!--    'column_alias': 'bookings'}                            -->
                         <!-- from_source = SqlSelectStatementNode(node_id=ss_11) -->
                         <!-- where = None -->
+                        <!-- distinct = False -->
                         <SqlSelectStatementNode>
                             <!-- description = Join Standard Outputs -->
                             <!-- node_id = ss_11 -->
@@ -131,6 +136,7 @@
                             <!--    'join_type': SqlJoinType.LEFT_OUTER,                     -->
                             <!--    'on_condition': SqlComparisonExpression(node_id=cmp_0)}  -->
                             <!-- where = None -->
+                            <!-- distinct = False -->
                             <SqlSelectStatementNode>
                                 <!-- description =                           -->
                                 <!--   Pass Only Elements:                   -->
@@ -150,6 +156,7 @@
                                 <!--    'column_alias': 'bookings'}                            -->
                                 <!-- from_source = SqlSelectStatementNode(node_id=ss_7) -->
                                 <!-- where = None -->
+                                <!-- distinct = False -->
                                 <SqlSelectStatementNode>
                                     <!-- description = Metric Time Dimension 'ds' -->
                                     <!-- node_id = ss_7 -->
@@ -547,6 +554,7 @@
                                     <!--    'column_alias': 'approximate_discrete_booking_value_p99'}  -->
                                     <!-- from_source = SqlSelectStatementNode(node_id=ss_10001) -->
                                     <!-- where = None -->
+                                    <!-- distinct = False -->
                                     <SqlSelectStatementNode>
                                         <!-- description = Read Elements From Semantic Model 'bookings_source' -->
                                         <!-- node_id = ss_10001 -->
@@ -904,6 +912,7 @@
                                         <!--    'column_alias': 'booking__host'}                         -->
                                         <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10001) -->
                                         <!-- where = None -->
+                                        <!-- distinct = False -->
                                         <SqlTableFromClauseNode>
                                             <!-- description = Read from ***************************.fct_bookings -->
                                             <!-- node_id = tfc_10001 -->
@@ -927,6 +936,7 @@
                                 <!--    'column_alias': 'country_latest'}                      -->
                                 <!-- from_source = SqlSelectStatementNode(node_id=ss_9) -->
                                 <!-- where = None -->
+                                <!-- distinct = False -->
                                 <SqlSelectStatementNode>
                                     <!-- description = Metric Time Dimension 'ds' -->
                                     <!-- node_id = ss_9 -->
@@ -1200,6 +1210,7 @@
                                     <!--    'column_alias': 'smallest_listing'}                    -->
                                     <!-- from_source = SqlSelectStatementNode(node_id=ss_10004) -->
                                     <!-- where = None -->
+                                    <!-- distinct = False -->
                                     <SqlSelectStatementNode>
                                         <!-- description = Read Elements From Semantic Model 'listings_latest' -->
                                         <!-- node_id = ss_10004 -->
@@ -1429,6 +1440,7 @@
                                         <!--    'column_alias': 'listing__user'}                         -->
                                         <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10004) -->
                                         <!-- where = None -->
+                                        <!-- distinct = False -->
                                         <SqlTableFromClauseNode>
                                             <!-- description = Read from ***************************.dim_listings_latest -->
                                             <!-- node_id = tfc_10004 -->
@@ -1458,6 +1470,7 @@
                 <!--    'column_alias': 'views'}                               -->
                 <!-- from_source = SqlSelectStatementNode(node_id=ss_21) -->
                 <!-- where = None -->
+                <!-- distinct = False -->
                 <SqlSelectStatementNode>
                     <!-- description = Aggregate Measures -->
                     <!-- node_id = ss_21 -->
@@ -1483,6 +1496,7 @@
                     <!--    'expr': SqlColumnReferenceExpression(node_id=cr_775),  -->
                     <!--    'column_alias': 'listing__country_latest'}             -->
                     <!-- where = None -->
+                    <!-- distinct = False -->
                     <SqlSelectStatementNode>
                         <!-- description =                                        -->
                         <!--   Pass Only Elements:                                -->
@@ -1502,6 +1516,7 @@
                         <!--    'column_alias': 'views'}                               -->
                         <!-- from_source = SqlSelectStatementNode(node_id=ss_19) -->
                         <!-- where = None -->
+                        <!-- distinct = False -->
                         <SqlSelectStatementNode>
                             <!-- description = Join Standard Outputs -->
                             <!-- node_id = ss_19 -->
@@ -1529,6 +1544,7 @@
                             <!--    'join_type': SqlJoinType.LEFT_OUTER,                     -->
                             <!--    'on_condition': SqlComparisonExpression(node_id=cmp_1)}  -->
                             <!-- where = None -->
+                            <!-- distinct = False -->
                             <SqlSelectStatementNode>
                                 <!-- description =                        -->
                                 <!--   Pass Only Elements:                -->
@@ -1548,6 +1564,7 @@
                                 <!--    'column_alias': 'views'}                               -->
                                 <!-- from_source = SqlSelectStatementNode(node_id=ss_15) -->
                                 <!-- where = None -->
+                                <!-- distinct = False -->
                                 <SqlSelectStatementNode>
                                     <!-- description = Metric Time Dimension 'ds' -->
                                     <!-- node_id = ss_15 -->
@@ -1793,6 +1810,7 @@
                                     <!--    'column_alias': 'views'}                               -->
                                     <!-- from_source = SqlSelectStatementNode(node_id=ss_10009) -->
                                     <!-- where = None -->
+                                    <!-- distinct = False -->
                                     <SqlSelectStatementNode>
                                         <!-- description = Read Elements From Semantic Model 'views_source' -->
                                         <!-- node_id = ss_10009 -->
@@ -1994,6 +2012,7 @@
                                         <!--    'column_alias': 'view__user'}                            -->
                                         <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10009) -->
                                         <!-- where = None -->
+                                        <!-- distinct = False -->
                                         <SqlTableFromClauseNode>
                                             <!-- description = Read from ***************************.fct_views -->
                                             <!-- node_id = tfc_10009 -->
@@ -2017,6 +2036,7 @@
                                 <!--    'column_alias': 'country_latest'}                      -->
                                 <!-- from_source = SqlSelectStatementNode(node_id=ss_17) -->
                                 <!-- where = None -->
+                                <!-- distinct = False -->
                                 <SqlSelectStatementNode>
                                     <!-- description = Metric Time Dimension 'ds' -->
                                     <!-- node_id = ss_17 -->
@@ -2290,6 +2310,7 @@
                                     <!--    'column_alias': 'smallest_listing'}                    -->
                                     <!-- from_source = SqlSelectStatementNode(node_id=ss_10004) -->
                                     <!-- where = None -->
+                                    <!-- distinct = False -->
                                     <SqlSelectStatementNode>
                                         <!-- description = Read Elements From Semantic Model 'listings_latest' -->
                                         <!-- node_id = ss_10004 -->
@@ -2519,6 +2540,7 @@
                                         <!--    'column_alias': 'listing__user'}                         -->
                                         <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10004) -->
                                         <!-- where = None -->
+                                        <!-- distinct = False -->
                                         <SqlTableFromClauseNode>
                                             <!-- description = Read from ***************************.dim_listings_latest -->
                                             <!-- node_id = tfc_10004 -->
diff --git a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_compute_metrics_node_ratio_from_single_semantic_model__plan0.xml b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_compute_metrics_node_ratio_from_single_semantic_model__plan0.xml
index 673a308906..b8ea0e4a87 100644
--- a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_compute_metrics_node_ratio_from_single_semantic_model__plan0.xml
+++ b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_compute_metrics_node_ratio_from_single_semantic_model__plan0.xml
@@ -16,6 +16,7 @@
         <!--    'column_alias': 'bookings_per_booker'}                -->
         <!-- from_source = SqlSelectStatementNode(node_id=ss_3) -->
         <!-- where = None -->
+        <!-- distinct = False -->
         <SqlSelectStatementNode>
             <!-- description = Aggregate Measures -->
             <!-- node_id = ss_3 -->
@@ -45,6 +46,7 @@
             <!--    'expr': SqlColumnReferenceExpression(node_id=cr_13),  -->
             <!--    'column_alias': 'listing__country_latest'}            -->
             <!-- where = None -->
+            <!-- distinct = False -->
             <SqlSelectStatementNode>
                 <!-- description = Join Standard Outputs -->
                 <!-- node_id = ss_2 -->
@@ -72,6 +74,7 @@
                 <!--    'join_type': SqlJoinType.LEFT_OUTER,                     -->
                 <!--    'on_condition': SqlComparisonExpression(node_id=cmp_0)}  -->
                 <!-- where = None -->
+                <!-- distinct = False -->
                 <SqlSelectStatementNode>
                     <!-- description =                           -->
                     <!--   Pass Only Elements:                   -->
@@ -91,6 +94,7 @@
                     <!--    'column_alias': 'bookers'}                           -->
                     <!-- from_source = SqlSelectStatementNode(node_id=ss_10001) -->
                     <!-- where = None -->
+                    <!-- distinct = False -->
                     <SqlSelectStatementNode>
                         <!-- description = Read Elements From Semantic Model 'bookings_source' -->
                         <!-- node_id = ss_10001 -->
@@ -448,6 +452,7 @@
                         <!--    'column_alias': 'booking__host'}                         -->
                         <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10001) -->
                         <!-- where = None -->
+                        <!-- distinct = False -->
                         <SqlTableFromClauseNode>
                             <!-- description = Read from ***************************.fct_bookings -->
                             <!-- node_id = tfc_10001 -->
@@ -470,6 +475,7 @@
                     <!--    'column_alias': 'country_latest'}                    -->
                     <!-- from_source = SqlSelectStatementNode(node_id=ss_10004) -->
                     <!-- where = None -->
+                    <!-- distinct = False -->
                     <SqlSelectStatementNode>
                         <!-- description = Read Elements From Semantic Model 'listings_latest' -->
                         <!-- node_id = ss_10004 -->
@@ -699,6 +705,7 @@
                         <!--    'column_alias': 'listing__user'}                         -->
                         <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10004) -->
                         <!-- where = None -->
+                        <!-- distinct = False -->
                         <SqlTableFromClauseNode>
                             <!-- description = Read from ***************************.dim_listings_latest -->
                             <!-- node_id = tfc_10004 -->
diff --git a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_compute_metrics_node_simple_expr__plan0.xml b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_compute_metrics_node_simple_expr__plan0.xml
index 26438e6ad2..d54260dadb 100644
--- a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_compute_metrics_node_simple_expr__plan0.xml
+++ b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_compute_metrics_node_simple_expr__plan0.xml
@@ -16,6 +16,7 @@
         <!--    'column_alias': 'booking_fees'}                                            -->
         <!-- from_source = SqlSelectStatementNode(node_id=ss_3) -->
         <!-- where = None -->
+        <!-- distinct = False -->
         <SqlSelectStatementNode>
             <!-- description = Aggregate Measures -->
             <!-- node_id = ss_3 -->
@@ -41,6 +42,7 @@
             <!--    'expr': SqlColumnReferenceExpression(node_id=cr_10),  -->
             <!--    'column_alias': 'listing__country_latest'}            -->
             <!-- where = None -->
+            <!-- distinct = False -->
             <SqlSelectStatementNode>
                 <!-- description = Join Standard Outputs -->
                 <!-- node_id = ss_2 -->
@@ -64,6 +66,7 @@
                 <!--    'join_type': SqlJoinType.LEFT_OUTER,                     -->
                 <!--    'on_condition': SqlComparisonExpression(node_id=cmp_0)}  -->
                 <!-- where = None -->
+                <!-- distinct = False -->
                 <SqlSelectStatementNode>
                     <!-- description =                     -->
                     <!--   Pass Only Elements:             -->
@@ -79,6 +82,7 @@
                     <!--    'column_alias': 'booking_value'}                     -->
                     <!-- from_source = SqlSelectStatementNode(node_id=ss_10001) -->
                     <!-- where = None -->
+                    <!-- distinct = False -->
                     <SqlSelectStatementNode>
                         <!-- description = Read Elements From Semantic Model 'bookings_source' -->
                         <!-- node_id = ss_10001 -->
@@ -436,6 +440,7 @@
                         <!--    'column_alias': 'booking__host'}                         -->
                         <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10001) -->
                         <!-- where = None -->
+                        <!-- distinct = False -->
                         <SqlTableFromClauseNode>
                             <!-- description = Read from ***************************.fct_bookings -->
                             <!-- node_id = tfc_10001 -->
@@ -458,6 +463,7 @@
                     <!--    'column_alias': 'country_latest'}                    -->
                     <!-- from_source = SqlSelectStatementNode(node_id=ss_10004) -->
                     <!-- where = None -->
+                    <!-- distinct = False -->
                     <SqlSelectStatementNode>
                         <!-- description = Read Elements From Semantic Model 'listings_latest' -->
                         <!-- node_id = ss_10004 -->
@@ -687,6 +693,7 @@
                         <!--    'column_alias': 'listing__user'}                         -->
                         <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10004) -->
                         <!-- where = None -->
+                        <!-- distinct = False -->
                         <SqlTableFromClauseNode>
                             <!-- description = Read from ***************************.dim_listings_latest -->
                             <!-- node_id = tfc_10004 -->
diff --git a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_constrain_time_range_node__plan0.xml b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_constrain_time_range_node__plan0.xml
index f502fba68f..2b515cea56 100644
--- a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_constrain_time_range_node__plan0.xml
+++ b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_constrain_time_range_node__plan0.xml
@@ -17,6 +17,7 @@
         <!--    'column_alias': 'bookings'}                          -->
         <!-- from_source = SqlSelectStatementNode(node_id=ss_1) -->
         <!-- where = SqlBetweenExpression(node_id=betw_0) -->
+        <!-- distinct = False -->
         <SqlSelectStatementNode>
             <!-- description = Metric Time Dimension 'ds' -->
             <!-- node_id = ss_1 -->
@@ -34,6 +35,7 @@
             <!--    'column_alias': 'bookings'}                          -->
             <!-- from_source = SqlSelectStatementNode(node_id=ss_0) -->
             <!-- where = None -->
+            <!-- distinct = False -->
             <SqlSelectStatementNode>
                 <!-- description =                -->
                 <!--   Pass Only Elements:        -->
@@ -49,6 +51,7 @@
                 <!--    'column_alias': 'bookings'}                          -->
                 <!-- from_source = SqlSelectStatementNode(node_id=ss_10001) -->
                 <!-- where = None -->
+                <!-- distinct = False -->
                 <SqlSelectStatementNode>
                     <!-- description = Read Elements From Semantic Model 'bookings_source' -->
                     <!-- node_id = ss_10001 -->
@@ -406,6 +409,7 @@
                     <!--    'column_alias': 'booking__host'}                         -->
                     <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10001) -->
                     <!-- where = None -->
+                    <!-- distinct = False -->
                     <SqlTableFromClauseNode>
                         <!-- description = Read from ***************************.fct_bookings -->
                         <!-- node_id = tfc_10001 -->
diff --git a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_filter_node__plan0.xml b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_filter_node__plan0.xml
index 507d162fbc..43d205cc89 100644
--- a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_filter_node__plan0.xml
+++ b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_filter_node__plan0.xml
@@ -10,6 +10,7 @@
         <!--    'column_alias': 'bookings'}                          -->
         <!-- from_source = SqlSelectStatementNode(node_id=ss_10001) -->
         <!-- where = None -->
+        <!-- distinct = False -->
         <SqlSelectStatementNode>
             <!-- description = Read Elements From Semantic Model 'bookings_source' -->
             <!-- node_id = ss_10001 -->
@@ -367,6 +368,7 @@
             <!--    'column_alias': 'booking__host'}                         -->
             <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10001) -->
             <!-- where = None -->
+            <!-- distinct = False -->
             <SqlTableFromClauseNode>
                 <!-- description = Read from ***************************.fct_bookings -->
                 <!-- node_id = tfc_10001 -->
diff --git a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_filter_with_where_constraint_node__plan0.xml b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_filter_with_where_constraint_node__plan0.xml
index 4ca58fa593..031d207292 100644
--- a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_filter_with_where_constraint_node__plan0.xml
+++ b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_filter_with_where_constraint_node__plan0.xml
@@ -13,6 +13,7 @@
         <!-- from_source = SqlSelectStatementNode(node_id=ss_0) -->
         <!-- where =                                                                        -->
         <!--   SqlStringExpression(node_id=str_0 sql_expr=booking__ds__day = '2020-01-01')  -->
+        <!-- distinct = False -->
         <SqlSelectStatementNode>
             <!-- description =                -->
             <!--   Pass Only Elements:        -->
@@ -28,6 +29,7 @@
             <!--    'column_alias': 'bookings'}                          -->
             <!-- from_source = SqlSelectStatementNode(node_id=ss_10001) -->
             <!-- where = None -->
+            <!-- distinct = False -->
             <SqlSelectStatementNode>
                 <!-- description = Read Elements From Semantic Model 'bookings_source' -->
                 <!-- node_id = ss_10001 -->
@@ -385,6 +387,7 @@
                 <!--    'column_alias': 'booking__host'}                         -->
                 <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10001) -->
                 <!-- where = None -->
+                <!-- distinct = False -->
                 <SqlTableFromClauseNode>
                     <!-- description = Read from ***************************.fct_bookings -->
                     <!-- node_id = tfc_10001 -->
diff --git a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_join_to_time_spine_node_with_offset_to_grain__plan0.xml b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_join_to_time_spine_node_with_offset_to_grain__plan0.xml
index da4b9f2c53..f15986b92a 100644
--- a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_join_to_time_spine_node_with_offset_to_grain__plan0.xml
+++ b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_join_to_time_spine_node_with_offset_to_grain__plan0.xml
@@ -22,6 +22,7 @@
         <!--    'join_type': SqlJoinType.INNER,                          -->
         <!--    'on_condition': SqlComparisonExpression(node_id=cmp_0)}  -->
         <!-- where = None -->
+        <!-- distinct = False -->
         <SqlSelectStatementNode>
             <!-- description = Date Spine -->
             <!-- node_id = ss_4 -->
@@ -31,6 +32,7 @@
             <!--    'column_alias': 'metric_time__day'}                    -->
             <!-- from_source = SqlTableFromClauseNode(node_id=tfc_0) -->
             <!-- where = SqlBetweenExpression(node_id=betw_0) -->
+            <!-- distinct = False -->
             <SqlTableFromClauseNode>
                 <!-- description = Read from ***************************.mf_time_spine -->
                 <!-- node_id = tfc_0 -->
@@ -54,6 +56,7 @@
             <!--    'column_alias': 'booking_fees'}                                            -->
             <!-- from_source = SqlSelectStatementNode(node_id=ss_2) -->
             <!-- where = None -->
+            <!-- distinct = False -->
             <SqlSelectStatementNode>
                 <!-- description = Aggregate Measures -->
                 <!-- node_id = ss_2 -->
@@ -79,6 +82,7 @@
                 <!--    'expr': SqlColumnReferenceExpression(node_id=cr_103),  -->
                 <!--    'column_alias': 'listing'}                             -->
                 <!-- where = None -->
+                <!-- distinct = False -->
                 <SqlSelectStatementNode>
                     <!-- description =                                         -->
                     <!--   Pass Only Elements:                                 -->
@@ -98,6 +102,7 @@
                     <!--    'column_alias': 'booking_value'}                      -->
                     <!-- from_source = SqlSelectStatementNode(node_id=ss_0) -->
                     <!-- where = None -->
+                    <!-- distinct = False -->
                     <SqlSelectStatementNode>
                         <!-- description = Metric Time Dimension 'ds' -->
                         <!-- node_id = ss_0 -->
@@ -495,6 +500,7 @@
                         <!--    'column_alias': 'approximate_discrete_booking_value_p99'}  -->
                         <!-- from_source = SqlSelectStatementNode(node_id=ss_10001) -->
                         <!-- where = None -->
+                        <!-- distinct = False -->
                         <SqlSelectStatementNode>
                             <!-- description = Read Elements From Semantic Model 'bookings_source' -->
                             <!-- node_id = ss_10001 -->
@@ -852,6 +858,7 @@
                             <!--    'column_alias': 'booking__host'}                         -->
                             <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10001) -->
                             <!-- where = None -->
+                            <!-- distinct = False -->
                             <SqlTableFromClauseNode>
                                 <!-- description = Read from ***************************.fct_bookings -->
                                 <!-- node_id = tfc_10001 -->
diff --git a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_join_to_time_spine_node_with_offset_window__plan0.xml b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_join_to_time_spine_node_with_offset_window__plan0.xml
index da4b9f2c53..f15986b92a 100644
--- a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_join_to_time_spine_node_with_offset_window__plan0.xml
+++ b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_join_to_time_spine_node_with_offset_window__plan0.xml
@@ -22,6 +22,7 @@
         <!--    'join_type': SqlJoinType.INNER,                          -->
         <!--    'on_condition': SqlComparisonExpression(node_id=cmp_0)}  -->
         <!-- where = None -->
+        <!-- distinct = False -->
         <SqlSelectStatementNode>
             <!-- description = Date Spine -->
             <!-- node_id = ss_4 -->
@@ -31,6 +32,7 @@
             <!--    'column_alias': 'metric_time__day'}                    -->
             <!-- from_source = SqlTableFromClauseNode(node_id=tfc_0) -->
             <!-- where = SqlBetweenExpression(node_id=betw_0) -->
+            <!-- distinct = False -->
             <SqlTableFromClauseNode>
                 <!-- description = Read from ***************************.mf_time_spine -->
                 <!-- node_id = tfc_0 -->
@@ -54,6 +56,7 @@
             <!--    'column_alias': 'booking_fees'}                                            -->
             <!-- from_source = SqlSelectStatementNode(node_id=ss_2) -->
             <!-- where = None -->
+            <!-- distinct = False -->
             <SqlSelectStatementNode>
                 <!-- description = Aggregate Measures -->
                 <!-- node_id = ss_2 -->
@@ -79,6 +82,7 @@
                 <!--    'expr': SqlColumnReferenceExpression(node_id=cr_103),  -->
                 <!--    'column_alias': 'listing'}                             -->
                 <!-- where = None -->
+                <!-- distinct = False -->
                 <SqlSelectStatementNode>
                     <!-- description =                                         -->
                     <!--   Pass Only Elements:                                 -->
@@ -98,6 +102,7 @@
                     <!--    'column_alias': 'booking_value'}                      -->
                     <!-- from_source = SqlSelectStatementNode(node_id=ss_0) -->
                     <!-- where = None -->
+                    <!-- distinct = False -->
                     <SqlSelectStatementNode>
                         <!-- description = Metric Time Dimension 'ds' -->
                         <!-- node_id = ss_0 -->
@@ -495,6 +500,7 @@
                         <!--    'column_alias': 'approximate_discrete_booking_value_p99'}  -->
                         <!-- from_source = SqlSelectStatementNode(node_id=ss_10001) -->
                         <!-- where = None -->
+                        <!-- distinct = False -->
                         <SqlSelectStatementNode>
                             <!-- description = Read Elements From Semantic Model 'bookings_source' -->
                             <!-- node_id = ss_10001 -->
@@ -852,6 +858,7 @@
                             <!--    'column_alias': 'booking__host'}                         -->
                             <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10001) -->
                             <!-- where = None -->
+                            <!-- distinct = False -->
                             <SqlTableFromClauseNode>
                                 <!-- description = Read from ***************************.fct_bookings -->
                                 <!-- node_id = tfc_10001 -->
diff --git a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_join_to_time_spine_node_without_offset__plan0.xml b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_join_to_time_spine_node_without_offset__plan0.xml
index da4b9f2c53..f15986b92a 100644
--- a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_join_to_time_spine_node_without_offset__plan0.xml
+++ b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_join_to_time_spine_node_without_offset__plan0.xml
@@ -22,6 +22,7 @@
         <!--    'join_type': SqlJoinType.INNER,                          -->
         <!--    'on_condition': SqlComparisonExpression(node_id=cmp_0)}  -->
         <!-- where = None -->
+        <!-- distinct = False -->
         <SqlSelectStatementNode>
             <!-- description = Date Spine -->
             <!-- node_id = ss_4 -->
@@ -31,6 +32,7 @@
             <!--    'column_alias': 'metric_time__day'}                    -->
             <!-- from_source = SqlTableFromClauseNode(node_id=tfc_0) -->
             <!-- where = SqlBetweenExpression(node_id=betw_0) -->
+            <!-- distinct = False -->
             <SqlTableFromClauseNode>
                 <!-- description = Read from ***************************.mf_time_spine -->
                 <!-- node_id = tfc_0 -->
@@ -54,6 +56,7 @@
             <!--    'column_alias': 'booking_fees'}                                            -->
             <!-- from_source = SqlSelectStatementNode(node_id=ss_2) -->
             <!-- where = None -->
+            <!-- distinct = False -->
             <SqlSelectStatementNode>
                 <!-- description = Aggregate Measures -->
                 <!-- node_id = ss_2 -->
@@ -79,6 +82,7 @@
                 <!--    'expr': SqlColumnReferenceExpression(node_id=cr_103),  -->
                 <!--    'column_alias': 'listing'}                             -->
                 <!-- where = None -->
+                <!-- distinct = False -->
                 <SqlSelectStatementNode>
                     <!-- description =                                         -->
                     <!--   Pass Only Elements:                                 -->
@@ -98,6 +102,7 @@
                     <!--    'column_alias': 'booking_value'}                      -->
                     <!-- from_source = SqlSelectStatementNode(node_id=ss_0) -->
                     <!-- where = None -->
+                    <!-- distinct = False -->
                     <SqlSelectStatementNode>
                         <!-- description = Metric Time Dimension 'ds' -->
                         <!-- node_id = ss_0 -->
@@ -495,6 +500,7 @@
                         <!--    'column_alias': 'approximate_discrete_booking_value_p99'}  -->
                         <!-- from_source = SqlSelectStatementNode(node_id=ss_10001) -->
                         <!-- where = None -->
+                        <!-- distinct = False -->
                         <SqlSelectStatementNode>
                             <!-- description = Read Elements From Semantic Model 'bookings_source' -->
                             <!-- node_id = ss_10001 -->
@@ -852,6 +858,7 @@
                             <!--    'column_alias': 'booking__host'}                         -->
                             <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10001) -->
                             <!-- where = None -->
+                            <!-- distinct = False -->
                             <SqlTableFromClauseNode>
                                 <!-- description = Read from ***************************.fct_bookings -->
                                 <!-- node_id = tfc_10001 -->
diff --git a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_measure_aggregation_node__plan0.xml b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_measure_aggregation_node__plan0.xml
index 9040ebdb0c..4d73ee2270 100644
--- a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_measure_aggregation_node__plan0.xml
+++ b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_measure_aggregation_node__plan0.xml
@@ -20,6 +20,7 @@
         <!--    'column_alias': 'average_booking_value'}                                      -->
         <!-- from_source = SqlSelectStatementNode(node_id=ss_0) -->
         <!-- where = None -->
+        <!-- distinct = False -->
         <SqlSelectStatementNode>
             <!-- description =                                                             -->
             <!--   Pass Only Elements:                                                     -->
@@ -43,6 +44,7 @@
             <!--    'column_alias': 'average_booking_value'}             -->
             <!-- from_source = SqlSelectStatementNode(node_id=ss_10001) -->
             <!-- where = None -->
+            <!-- distinct = False -->
             <SqlSelectStatementNode>
                 <!-- description = Read Elements From Semantic Model 'bookings_source' -->
                 <!-- node_id = ss_10001 -->
@@ -400,6 +402,7 @@
                 <!--    'column_alias': 'booking__host'}                         -->
                 <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10001) -->
                 <!-- where = None -->
+                <!-- distinct = False -->
                 <SqlTableFromClauseNode>
                     <!-- description = Read from ***************************.fct_bookings -->
                     <!-- node_id = tfc_10001 -->
diff --git a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_multi_join_node__plan0.xml b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_multi_join_node__plan0.xml
index 86d176f9cb..3268ab93ba 100644
--- a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_multi_join_node__plan0.xml
+++ b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_multi_join_node__plan0.xml
@@ -32,6 +32,7 @@
         <!--    'join_type': SqlJoinType.LEFT_OUTER,                     -->
         <!--    'on_condition': SqlComparisonExpression(node_id=cmp_1)}  -->
         <!-- where = None -->
+        <!-- distinct = False -->
         <SqlSelectStatementNode>
             <!-- description =                -->
             <!--   Pass Only Elements:        -->
@@ -47,6 +48,7 @@
             <!--    'column_alias': 'bookings'}                          -->
             <!-- from_source = SqlSelectStatementNode(node_id=ss_10001) -->
             <!-- where = None -->
+            <!-- distinct = False -->
             <SqlSelectStatementNode>
                 <!-- description = Read Elements From Semantic Model 'bookings_source' -->
                 <!-- node_id = ss_10001 -->
@@ -404,6 +406,7 @@
                 <!--    'column_alias': 'booking__host'}                         -->
                 <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10001) -->
                 <!-- where = None -->
+                <!-- distinct = False -->
                 <SqlTableFromClauseNode>
                     <!-- description = Read from ***************************.fct_bookings -->
                     <!-- node_id = tfc_10001 -->
@@ -426,6 +429,7 @@
             <!--    'column_alias': 'country_latest'}                    -->
             <!-- from_source = SqlSelectStatementNode(node_id=ss_10004) -->
             <!-- where = None -->
+            <!-- distinct = False -->
             <SqlSelectStatementNode>
                 <!-- description = Read Elements From Semantic Model 'listings_latest' -->
                 <!-- node_id = ss_10004 -->
@@ -655,6 +659,7 @@
                 <!--    'column_alias': 'listing__user'}                         -->
                 <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10004) -->
                 <!-- where = None -->
+                <!-- distinct = False -->
                 <SqlTableFromClauseNode>
                     <!-- description = Read from ***************************.dim_listings_latest -->
                     <!-- node_id = tfc_10004 -->
@@ -677,6 +682,7 @@
             <!--    'column_alias': 'country_latest'}                    -->
             <!-- from_source = SqlSelectStatementNode(node_id=ss_10004) -->
             <!-- where = None -->
+            <!-- distinct = False -->
             <SqlSelectStatementNode>
                 <!-- description = Read Elements From Semantic Model 'listings_latest' -->
                 <!-- node_id = ss_10004 -->
@@ -906,6 +912,7 @@
                 <!--    'column_alias': 'listing__user'}                         -->
                 <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10004) -->
                 <!-- where = None -->
+                <!-- distinct = False -->
                 <SqlTableFromClauseNode>
                     <!-- description = Read from ***************************.dim_listings_latest -->
                     <!-- node_id = tfc_10004 -->
diff --git a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_order_by_node__plan0.xml b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_order_by_node__plan0.xml
index 402e2ef39d..76e0ba86fd 100644
--- a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_order_by_node__plan0.xml
+++ b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_order_by_node__plan0.xml
@@ -24,6 +24,7 @@
         <!--   {'class': 'SqlOrderByDescription',                     -->
         <!--    'expr': SqlColumnReferenceExpression(node_id=cr_10),  -->
         <!--    'desc': True}                                         -->
+        <!-- distinct = False -->
         <SqlSelectStatementNode>
             <!-- description = Compute Metrics via Expressions -->
             <!-- node_id = ss_2 -->
@@ -41,6 +42,7 @@
             <!--    'column_alias': 'bookings'}                          -->
             <!-- from_source = SqlSelectStatementNode(node_id=ss_1) -->
             <!-- where = None -->
+            <!-- distinct = False -->
             <SqlSelectStatementNode>
                 <!-- description = Aggregate Measures -->
                 <!-- node_id = ss_1 -->
@@ -66,6 +68,7 @@
                 <!--    'expr': SqlColumnReferenceExpression(node_id=cr_4),  -->
                 <!--    'column_alias': 'is_instant'}                        -->
                 <!-- where = None -->
+                <!-- distinct = False -->
                 <SqlSelectStatementNode>
                     <!-- description =                              -->
                     <!--   Pass Only Elements:                      -->
@@ -85,6 +88,7 @@
                     <!--    'column_alias': 'bookings'}                          -->
                     <!-- from_source = SqlSelectStatementNode(node_id=ss_10001) -->
                     <!-- where = None -->
+                    <!-- distinct = False -->
                     <SqlSelectStatementNode>
                         <!-- description = Read Elements From Semantic Model 'bookings_source' -->
                         <!-- node_id = ss_10001 -->
@@ -442,6 +446,7 @@
                         <!--    'column_alias': 'booking__host'}                         -->
                         <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10001) -->
                         <!-- where = None -->
+                        <!-- distinct = False -->
                         <SqlTableFromClauseNode>
                             <!-- description = Read from ***************************.fct_bookings -->
                             <!-- node_id = tfc_10001 -->
diff --git a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_semi_additive_join_node__plan0.xml b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_semi_additive_join_node__plan0.xml
index 3b31be5065..187f6f44d1 100644
--- a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_semi_additive_join_node__plan0.xml
+++ b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_semi_additive_join_node__plan0.xml
@@ -126,6 +126,7 @@
         <!--    'join_type': SqlJoinType.INNER,                          -->
         <!--    'on_condition': SqlComparisonExpression(node_id=cmp_0)}  -->
         <!-- where = None -->
+        <!-- distinct = False -->
         <SqlSelectStatementNode>
             <!-- description = Read Elements From Semantic Model 'accounts_source' -->
             <!-- node_id = ss_10000 -->
@@ -247,6 +248,7 @@
             <!--    'column_alias': 'account__user'}                         -->
             <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10000) -->
             <!-- where = None -->
+            <!-- distinct = False -->
             <SqlTableFromClauseNode>
                 <!-- description = Read from ***************************.fct_accounts -->
                 <!-- node_id = tfc_10000 -->
@@ -262,6 +264,7 @@
             <!--    'column_alias': 'ds__day__complete'}                                      -->
             <!-- from_source = SqlSelectStatementNode(node_id=ss_10000) -->
             <!-- where = None -->
+            <!-- distinct = False -->
             <SqlSelectStatementNode>
                 <!-- description = Read Elements From Semantic Model 'accounts_source' -->
                 <!-- node_id = ss_10000 -->
@@ -383,6 +386,7 @@
                 <!--    'column_alias': 'account__user'}                         -->
                 <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10000) -->
                 <!-- where = None -->
+                <!-- distinct = False -->
                 <SqlTableFromClauseNode>
                     <!-- description = Read from ***************************.fct_accounts -->
                     <!-- node_id = tfc_10000 -->
diff --git a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_semi_additive_join_node_with_grouping__plan0.xml b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_semi_additive_join_node_with_grouping__plan0.xml
index c4d1d06282..364d97e86d 100644
--- a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_semi_additive_join_node_with_grouping__plan0.xml
+++ b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_semi_additive_join_node_with_grouping__plan0.xml
@@ -126,6 +126,7 @@
         <!--    'join_type': SqlJoinType.INNER,                        -->
         <!--    'on_condition': SqlLogicalExpression(node_id=lo_0)}    -->
         <!-- where = None -->
+        <!-- distinct = False -->
         <SqlSelectStatementNode>
             <!-- description = Read Elements From Semantic Model 'accounts_source' -->
             <!-- node_id = ss_10000 -->
@@ -247,6 +248,7 @@
             <!--    'column_alias': 'account__user'}                         -->
             <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10000) -->
             <!-- where = None -->
+            <!-- distinct = False -->
             <SqlTableFromClauseNode>
                 <!-- description = Read from ***************************.fct_accounts -->
                 <!-- node_id = tfc_10000 -->
@@ -270,6 +272,7 @@
             <!--    'expr': SqlColumnReferenceExpression(node_id=cr_1),  -->
             <!--    'column_alias': 'user'}                              -->
             <!-- where = None -->
+            <!-- distinct = False -->
             <SqlSelectStatementNode>
                 <!-- description = Read Elements From Semantic Model 'accounts_source' -->
                 <!-- node_id = ss_10000 -->
@@ -391,6 +394,7 @@
                 <!--    'column_alias': 'account__user'}                         -->
                 <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10000) -->
                 <!-- where = None -->
+                <!-- distinct = False -->
                 <SqlTableFromClauseNode>
                     <!-- description = Read from ***************************.fct_accounts -->
                     <!-- node_id = tfc_10000 -->
diff --git a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_semi_additive_join_node_with_queried_group_by__plan0.xml b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_semi_additive_join_node_with_queried_group_by__plan0.xml
index c65adb8572..c877290f10 100644
--- a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_semi_additive_join_node_with_queried_group_by__plan0.xml
+++ b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_semi_additive_join_node_with_queried_group_by__plan0.xml
@@ -126,6 +126,7 @@
         <!--    'join_type': SqlJoinType.INNER,                          -->
         <!--    'on_condition': SqlComparisonExpression(node_id=cmp_0)}  -->
         <!-- where = None -->
+        <!-- distinct = False -->
         <SqlSelectStatementNode>
             <!-- description = Read Elements From Semantic Model 'accounts_source' -->
             <!-- node_id = ss_10000 -->
@@ -247,6 +248,7 @@
             <!--    'column_alias': 'account__user'}                         -->
             <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10000) -->
             <!-- where = None -->
+            <!-- distinct = False -->
             <SqlTableFromClauseNode>
                 <!-- description = Read from ***************************.fct_accounts -->
                 <!-- node_id = tfc_10000 -->
@@ -270,6 +272,7 @@
             <!--    'expr': SqlColumnReferenceExpression(node_id=cr_1),  -->
             <!--    'column_alias': 'ds__week'}                          -->
             <!-- where = None -->
+            <!-- distinct = False -->
             <SqlSelectStatementNode>
                 <!-- description = Read Elements From Semantic Model 'accounts_source' -->
                 <!-- node_id = ss_10000 -->
@@ -391,6 +394,7 @@
                 <!--    'column_alias': 'account__user'}                         -->
                 <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10000) -->
                 <!-- where = None -->
+                <!-- distinct = False -->
                 <SqlTableFromClauseNode>
                     <!-- description = Read from ***************************.fct_accounts -->
                     <!-- node_id = tfc_10000 -->
diff --git a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_single_join_node__plan0.xml b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_single_join_node__plan0.xml
index 48afce360f..ab795d1fad 100644
--- a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_single_join_node__plan0.xml
+++ b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_single_join_node__plan0.xml
@@ -18,6 +18,7 @@
         <!--    'join_type': SqlJoinType.LEFT_OUTER,                     -->
         <!--    'on_condition': SqlComparisonExpression(node_id=cmp_0)}  -->
         <!-- where = None -->
+        <!-- distinct = False -->
         <SqlSelectStatementNode>
             <!-- description =                -->
             <!--   Pass Only Elements:        -->
@@ -33,6 +34,7 @@
             <!--    'column_alias': 'bookings'}                          -->
             <!-- from_source = SqlSelectStatementNode(node_id=ss_10001) -->
             <!-- where = None -->
+            <!-- distinct = False -->
             <SqlSelectStatementNode>
                 <!-- description = Read Elements From Semantic Model 'bookings_source' -->
                 <!-- node_id = ss_10001 -->
@@ -390,6 +392,7 @@
                 <!--    'column_alias': 'booking__host'}                         -->
                 <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10001) -->
                 <!-- where = None -->
+                <!-- distinct = False -->
                 <SqlTableFromClauseNode>
                     <!-- description = Read from ***************************.fct_bookings -->
                     <!-- node_id = tfc_10001 -->
@@ -412,6 +415,7 @@
             <!--    'column_alias': 'listing__country_latest'}           -->
             <!-- from_source = SqlSelectStatementNode(node_id=ss_10004) -->
             <!-- where = None -->
+            <!-- distinct = False -->
             <SqlSelectStatementNode>
                 <!-- description = Read Elements From Semantic Model 'listings_latest' -->
                 <!-- node_id = ss_10004 -->
@@ -641,6 +645,7 @@
                 <!--    'column_alias': 'listing__user'}                         -->
                 <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10004) -->
                 <!-- where = None -->
+                <!-- distinct = False -->
                 <SqlTableFromClauseNode>
                     <!-- description = Read from ***************************.dim_listings_latest -->
                     <!-- node_id = tfc_10004 -->
diff --git a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_source_node__plan0.xml b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_source_node__plan0.xml
index 89948cc666..13fda71ede 100644
--- a/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_source_node__plan0.xml
+++ b/metricflow/test/snapshots/test_dataflow_to_sql_plan.py/SqlQueryPlan/test_source_node__plan0.xml
@@ -356,6 +356,7 @@
         <!--    'column_alias': 'booking__host'}                         -->
         <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10001) -->
         <!-- where = None -->
+        <!-- distinct = False -->
         <SqlTableFromClauseNode>
             <!-- description = Read from ***************************.fct_bookings -->
             <!-- node_id = tfc_10001 -->
diff --git a/metricflow/test/snapshots/test_metric_time_dimension_to_sql.py/SqlQueryPlan/test_metric_time_dimension_transform_node_using_non_primary_time__plan0.xml b/metricflow/test/snapshots/test_metric_time_dimension_to_sql.py/SqlQueryPlan/test_metric_time_dimension_transform_node_using_non_primary_time__plan0.xml
index 2e1a787a23..18da8dd77c 100644
--- a/metricflow/test/snapshots/test_metric_time_dimension_to_sql.py/SqlQueryPlan/test_metric_time_dimension_transform_node_using_non_primary_time__plan0.xml
+++ b/metricflow/test/snapshots/test_metric_time_dimension_to_sql.py/SqlQueryPlan/test_metric_time_dimension_transform_node_using_non_primary_time__plan0.xml
@@ -348,6 +348,7 @@
         <!--    'column_alias': 'booking_payments'}                  -->
         <!-- from_source = SqlSelectStatementNode(node_id=ss_10001) -->
         <!-- where = None -->
+        <!-- distinct = False -->
         <SqlSelectStatementNode>
             <!-- description = Read Elements From Semantic Model 'bookings_source' -->
             <!-- node_id = ss_10001 -->
@@ -705,6 +706,7 @@
             <!--    'column_alias': 'booking__host'}                         -->
             <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10001) -->
             <!-- where = None -->
+            <!-- distinct = False -->
             <SqlTableFromClauseNode>
                 <!-- description = Read from ***************************.fct_bookings -->
                 <!-- node_id = tfc_10001 -->
diff --git a/metricflow/test/snapshots/test_metric_time_dimension_to_sql.py/SqlQueryPlan/test_metric_time_dimension_transform_node_using_primary_time__plan0.xml b/metricflow/test/snapshots/test_metric_time_dimension_to_sql.py/SqlQueryPlan/test_metric_time_dimension_transform_node_using_primary_time__plan0.xml
index db9f23a206..74cd78ad59 100644
--- a/metricflow/test/snapshots/test_metric_time_dimension_to_sql.py/SqlQueryPlan/test_metric_time_dimension_transform_node_using_primary_time__plan0.xml
+++ b/metricflow/test/snapshots/test_metric_time_dimension_to_sql.py/SqlQueryPlan/test_metric_time_dimension_transform_node_using_primary_time__plan0.xml
@@ -396,6 +396,7 @@
         <!--    'column_alias': 'approximate_discrete_booking_value_p99'}  -->
         <!-- from_source = SqlSelectStatementNode(node_id=ss_10001) -->
         <!-- where = None -->
+        <!-- distinct = False -->
         <SqlSelectStatementNode>
             <!-- description = Read Elements From Semantic Model 'bookings_source' -->
             <!-- node_id = ss_10001 -->
@@ -753,6 +754,7 @@
             <!--    'column_alias': 'booking__host'}                         -->
             <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10001) -->
             <!-- where = None -->
+            <!-- distinct = False -->
             <SqlTableFromClauseNode>
                 <!-- description = Read from ***************************.fct_bookings -->
                 <!-- node_id = tfc_10001 -->
diff --git a/metricflow/test/snapshots/test_metric_time_dimension_to_sql.py/SqlQueryPlan/test_simple_query_with_metric_time_dimension__plan0.xml b/metricflow/test/snapshots/test_metric_time_dimension_to_sql.py/SqlQueryPlan/test_simple_query_with_metric_time_dimension__plan0.xml
index e8cd14dee9..3ade70ad35 100644
--- a/metricflow/test/snapshots/test_metric_time_dimension_to_sql.py/SqlQueryPlan/test_simple_query_with_metric_time_dimension__plan0.xml
+++ b/metricflow/test/snapshots/test_metric_time_dimension_to_sql.py/SqlQueryPlan/test_simple_query_with_metric_time_dimension__plan0.xml
@@ -26,6 +26,7 @@
         <!--    'expr': SqlAggregateFunctionExpression(node_id=fnc_4, sql_function=COALESCE),  -->
         <!--    'column_alias': 'metric_time__day'}                                            -->
         <!-- where = None -->
+        <!-- distinct = False -->
         <SqlSelectStatementNode>
             <!-- description = Compute Metrics via Expressions -->
             <!-- node_id = ss_10 -->
@@ -39,6 +40,7 @@
             <!--    'column_alias': 'bookings'}                            -->
             <!-- from_source = SqlSelectStatementNode(node_id=ss_9) -->
             <!-- where = None -->
+            <!-- distinct = False -->
             <SqlSelectStatementNode>
                 <!-- description = Aggregate Measures -->
                 <!-- node_id = ss_9 -->
@@ -56,6 +58,7 @@
                 <!--    'expr': SqlColumnReferenceExpression(node_id=cr_549),  -->
                 <!--    'column_alias': 'metric_time__day'}                    -->
                 <!-- where = None -->
+                <!-- distinct = False -->
                 <SqlSelectStatementNode>
                     <!-- description =                         -->
                     <!--   Pass Only Elements:                 -->
@@ -71,6 +74,7 @@
                     <!--    'column_alias': 'bookings'}                            -->
                     <!-- from_source = SqlSelectStatementNode(node_id=ss_7) -->
                     <!-- where = None -->
+                    <!-- distinct = False -->
                     <SqlSelectStatementNode>
                         <!-- description = Metric Time Dimension 'ds' -->
                         <!-- node_id = ss_7 -->
@@ -468,6 +472,7 @@
                         <!--    'column_alias': 'approximate_discrete_booking_value_p99'}  -->
                         <!-- from_source = SqlSelectStatementNode(node_id=ss_10001) -->
                         <!-- where = None -->
+                        <!-- distinct = False -->
                         <SqlSelectStatementNode>
                             <!-- description = Read Elements From Semantic Model 'bookings_source' -->
                             <!-- node_id = ss_10001 -->
@@ -825,6 +830,7 @@
                             <!--    'column_alias': 'booking__host'}                         -->
                             <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10001) -->
                             <!-- where = None -->
+                            <!-- distinct = False -->
                             <SqlTableFromClauseNode>
                                 <!-- description = Read from ***************************.fct_bookings -->
                                 <!-- node_id = tfc_10001 -->
@@ -848,6 +854,7 @@
             <!--    'column_alias': 'booking_payments'}                    -->
             <!-- from_source = SqlSelectStatementNode(node_id=ss_13) -->
             <!-- where = None -->
+            <!-- distinct = False -->
             <SqlSelectStatementNode>
                 <!-- description = Aggregate Measures -->
                 <!-- node_id = ss_13 -->
@@ -865,6 +872,7 @@
                 <!--    'expr': SqlColumnReferenceExpression(node_id=cr_641),  -->
                 <!--    'column_alias': 'metric_time__day'}                    -->
                 <!-- where = None -->
+                <!-- distinct = False -->
                 <SqlSelectStatementNode>
                     <!-- description =                                 -->
                     <!--   Pass Only Elements:                         -->
@@ -880,6 +888,7 @@
                     <!--    'column_alias': 'booking_payments'}                    -->
                     <!-- from_source = SqlSelectStatementNode(node_id=ss_11) -->
                     <!-- where = None -->
+                    <!-- distinct = False -->
                     <SqlSelectStatementNode>
                         <!-- description = Metric Time Dimension 'paid_at' -->
                         <!-- node_id = ss_11 -->
@@ -1229,6 +1238,7 @@
                         <!--    'column_alias': 'booking_payments'}                    -->
                         <!-- from_source = SqlSelectStatementNode(node_id=ss_10001) -->
                         <!-- where = None -->
+                        <!-- distinct = False -->
                         <SqlSelectStatementNode>
                             <!-- description = Read Elements From Semantic Model 'bookings_source' -->
                             <!-- node_id = ss_10001 -->
@@ -1586,6 +1596,7 @@
                             <!--    'column_alias': 'booking__host'}                         -->
                             <!-- from_source = SqlTableFromClauseNode(node_id=tfc_10001) -->
                             <!-- where = None -->
+                            <!-- distinct = False -->
                             <SqlTableFromClauseNode>
                                 <!-- description = Read from ***************************.fct_bookings -->
                                 <!-- node_id = tfc_10001 -->
diff --git a/metricflow/test/snapshots/test_rewriting_sub_query_reducer.py/SqlQueryPlan/test_rewriting_distinct_select_node_is_not_reduced__after_reducing.sql b/metricflow/test/snapshots/test_rewriting_sub_query_reducer.py/SqlQueryPlan/test_rewriting_distinct_select_node_is_not_reduced__after_reducing.sql
new file mode 100644
index 0000000000..9acdadd458
--- /dev/null
+++ b/metricflow/test/snapshots/test_rewriting_sub_query_reducer.py/SqlQueryPlan/test_rewriting_distinct_select_node_is_not_reduced__after_reducing.sql
@@ -0,0 +1,10 @@
+-- test0
+SELECT
+  a.booking_value
+FROM (
+  -- test1
+  SELECT DISTINCT
+    a.booking_value
+    , a.bookings
+  FROM demo.fct_bookings a
+) b
diff --git a/metricflow/test/snapshots/test_rewriting_sub_query_reducer.py/SqlQueryPlan/test_rewriting_distinct_select_node_is_not_reduced__before_reducing.sql b/metricflow/test/snapshots/test_rewriting_sub_query_reducer.py/SqlQueryPlan/test_rewriting_distinct_select_node_is_not_reduced__before_reducing.sql
new file mode 100644
index 0000000000..9acdadd458
--- /dev/null
+++ b/metricflow/test/snapshots/test_rewriting_sub_query_reducer.py/SqlQueryPlan/test_rewriting_distinct_select_node_is_not_reduced__before_reducing.sql
@@ -0,0 +1,10 @@
+-- test0
+SELECT
+  a.booking_value
+FROM (
+  -- test1
+  SELECT DISTINCT
+    a.booking_value
+    , a.bookings
+  FROM demo.fct_bookings a
+) b
diff --git a/metricflow/test/snapshots/test_sub_query_reducer.py/SqlQueryPlan/test_distinct_select_node_is_not_reduced__after_reducing.sql b/metricflow/test/snapshots/test_sub_query_reducer.py/SqlQueryPlan/test_distinct_select_node_is_not_reduced__after_reducing.sql
new file mode 100644
index 0000000000..9acdadd458
--- /dev/null
+++ b/metricflow/test/snapshots/test_sub_query_reducer.py/SqlQueryPlan/test_distinct_select_node_is_not_reduced__after_reducing.sql
@@ -0,0 +1,10 @@
+-- test0
+SELECT
+  a.booking_value
+FROM (
+  -- test1
+  SELECT DISTINCT
+    a.booking_value
+    , a.bookings
+  FROM demo.fct_bookings a
+) b
diff --git a/metricflow/test/snapshots/test_sub_query_reducer.py/SqlQueryPlan/test_distinct_select_node_is_not_reduced__before_reducing.sql b/metricflow/test/snapshots/test_sub_query_reducer.py/SqlQueryPlan/test_distinct_select_node_is_not_reduced__before_reducing.sql
new file mode 100644
index 0000000000..9acdadd458
--- /dev/null
+++ b/metricflow/test/snapshots/test_sub_query_reducer.py/SqlQueryPlan/test_distinct_select_node_is_not_reduced__before_reducing.sql
@@ -0,0 +1,10 @@
+-- test0
+SELECT
+  a.booking_value
+FROM (
+  -- test1
+  SELECT DISTINCT
+    a.booking_value
+    , a.bookings
+  FROM demo.fct_bookings a
+) b