From e4c430f54bc243657cc7b5a28b9068e683de965c Mon Sep 17 00:00:00 2001
From: Paul Yang <github@ardorful.com>
Date: Tue, 28 May 2024 18:17:31 -0700
Subject: [PATCH] Update snapshots for rename to
 `SelectSqlQueryToDataTableTask`.

---
 .../BigQuery/test_combined_metrics_plan__ep_0.xml             | 4 ++--
 .../ExecutionPlan/BigQuery/test_joined_plan__ep_0.xml         | 4 ++--
 .../BigQuery/test_multihop_joined_plan__ep_0.xml              | 4 ++--
 .../BigQuery/test_small_combined_metrics_plan__ep_0.xml       | 4 ++--
 .../Databricks/test_combined_metrics_plan__ep_0.xml           | 4 ++--
 .../ExecutionPlan/Databricks/test_joined_plan__ep_0.xml       | 4 ++--
 .../Databricks/test_multihop_joined_plan__ep_0.xml            | 4 ++--
 .../Databricks/test_small_combined_metrics_plan__ep_0.xml     | 4 ++--
 .../ExecutionPlan/DuckDB/test_combined_metrics_plan__ep_0.xml | 4 ++--
 .../ExecutionPlan/DuckDB/test_joined_plan__ep_0.xml           | 4 ++--
 .../ExecutionPlan/DuckDB/test_multihop_joined_plan__ep_0.xml  | 4 ++--
 .../DuckDB/test_small_combined_metrics_plan__ep_0.xml         | 4 ++--
 .../Postgres/test_combined_metrics_plan__ep_0.xml             | 4 ++--
 .../ExecutionPlan/Postgres/test_joined_plan__ep_0.xml         | 4 ++--
 .../Postgres/test_multihop_joined_plan__ep_0.xml              | 4 ++--
 .../Postgres/test_small_combined_metrics_plan__ep_0.xml       | 4 ++--
 .../Redshift/test_combined_metrics_plan__ep_0.xml             | 4 ++--
 .../ExecutionPlan/Redshift/test_joined_plan__ep_0.xml         | 4 ++--
 .../Redshift/test_multihop_joined_plan__ep_0.xml              | 4 ++--
 .../Redshift/test_small_combined_metrics_plan__ep_0.xml       | 4 ++--
 .../Snowflake/test_combined_metrics_plan__ep_0.xml            | 4 ++--
 .../ExecutionPlan/Snowflake/test_joined_plan__ep_0.xml        | 4 ++--
 .../Snowflake/test_multihop_joined_plan__ep_0.xml             | 4 ++--
 .../Snowflake/test_small_combined_metrics_plan__ep_0.xml      | 4 ++--
 .../ExecutionPlan/Trino/test_combined_metrics_plan__ep_0.xml  | 4 ++--
 .../ExecutionPlan/Trino/test_joined_plan__ep_0.xml            | 4 ++--
 .../ExecutionPlan/Trino/test_multihop_joined_plan__ep_0.xml   | 4 ++--
 .../Trino/test_small_combined_metrics_plan__ep_0.xml          | 4 ++--
 28 files changed, 56 insertions(+), 56 deletions(-)

diff --git a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/BigQuery/test_combined_metrics_plan__ep_0.xml b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/BigQuery/test_combined_metrics_plan__ep_0.xml
index e7279fbd12..64512a66a6 100644
--- a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/BigQuery/test_combined_metrics_plan__ep_0.xml
+++ b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/BigQuery/test_combined_metrics_plan__ep_0.xml
@@ -1,5 +1,5 @@
 <ExecutionPlan>
-    <SelectSqlQueryToDataFrameTask>
+    <SelectSqlQueryToDataTableTask>
         <!-- description = 'Run a query and write the results to a data frame' -->
         <!-- node_id = NodeId(id_str='rsq_0') -->
         <!-- sql_query =                                                                                 -->
@@ -82,5 +82,5 @@
         <!--    'GROUP BY\n'                                                                             -->
         <!--    '  ds__day\n'                                                                            -->
         <!--    '  , is_instant')                                                                        -->
-    </SelectSqlQueryToDataFrameTask>
+    </SelectSqlQueryToDataTableTask>
 </ExecutionPlan>
diff --git a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/BigQuery/test_joined_plan__ep_0.xml b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/BigQuery/test_joined_plan__ep_0.xml
index 1f70c9467e..8fccf02d64 100644
--- a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/BigQuery/test_joined_plan__ep_0.xml
+++ b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/BigQuery/test_joined_plan__ep_0.xml
@@ -1,5 +1,5 @@
 <ExecutionPlan>
-    <SelectSqlQueryToDataFrameTask>
+    <SelectSqlQueryToDataTableTask>
         <!-- description = 'Run a query and write the results to a data frame' -->
         <!-- node_id = NodeId(id_str='rsq_0') -->
         <!-- sql_query =                                                                         -->
@@ -28,5 +28,5 @@
         <!--    'GROUP BY\n'                                                                     -->
         <!--    '  is_instant\n'                                                                 -->
         <!--    '  , listing__country_latest')                                                   -->
-    </SelectSqlQueryToDataFrameTask>
+    </SelectSqlQueryToDataTableTask>
 </ExecutionPlan>
diff --git a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/BigQuery/test_multihop_joined_plan__ep_0.xml b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/BigQuery/test_multihop_joined_plan__ep_0.xml
index 52203b0845..72dfca3d9f 100644
--- a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/BigQuery/test_multihop_joined_plan__ep_0.xml
+++ b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/BigQuery/test_multihop_joined_plan__ep_0.xml
@@ -1,5 +1,5 @@
 <ExecutionPlan>
-    <SelectSqlQueryToDataFrameTask>
+    <SelectSqlQueryToDataTableTask>
         <!-- description = 'Run a query and write the results to a data frame' -->
         <!-- node_id = NodeId(id_str='rsq_0') -->
         <!-- sql_query =                                                                                             -->
@@ -37,5 +37,5 @@
         <!--    '  )\n'                                                                                              -->
         <!--    'GROUP BY\n'                                                                                         -->
         <!--    '  account_id__customer_id__customer_name')                                                          -->
-    </SelectSqlQueryToDataFrameTask>
+    </SelectSqlQueryToDataTableTask>
 </ExecutionPlan>
diff --git a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/BigQuery/test_small_combined_metrics_plan__ep_0.xml b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/BigQuery/test_small_combined_metrics_plan__ep_0.xml
index 9045376fc5..b1df474f4c 100644
--- a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/BigQuery/test_small_combined_metrics_plan__ep_0.xml
+++ b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/BigQuery/test_small_combined_metrics_plan__ep_0.xml
@@ -1,5 +1,5 @@
 <ExecutionPlan>
-    <SelectSqlQueryToDataFrameTask>
+    <SelectSqlQueryToDataTableTask>
         <!-- description = 'Run a query and write the results to a data frame' -->
         <!-- node_id = NodeId(id_str='rsq_0') -->
         <!-- sql_query =                                                                        -->
@@ -43,5 +43,5 @@
         <!--    '  subq_4.is_instant = subq_9.is_instant\n'                                     -->
         <!--    'GROUP BY\n'                                                                    -->
         <!--    '  is_instant')                                                                 -->
-    </SelectSqlQueryToDataFrameTask>
+    </SelectSqlQueryToDataTableTask>
 </ExecutionPlan>
diff --git a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Databricks/test_combined_metrics_plan__ep_0.xml b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Databricks/test_combined_metrics_plan__ep_0.xml
index 30ef3132d1..16ed0e7902 100644
--- a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Databricks/test_combined_metrics_plan__ep_0.xml
+++ b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Databricks/test_combined_metrics_plan__ep_0.xml
@@ -1,5 +1,5 @@
 <ExecutionPlan>
-    <SelectSqlQueryToDataFrameTask>
+    <SelectSqlQueryToDataTableTask>
         <!-- description = 'Run a query and write the results to a data frame' -->
         <!-- node_id = NodeId(id_str='rsq_0') -->
         <!-- sql_query =                                                                                 -->
@@ -82,5 +82,5 @@
         <!--    'GROUP BY\n'                                                                             -->
         <!--    '  COALESCE(subq_4.ds__day, subq_9.ds__day, subq_14.ds__day)\n'                          -->
         <!--    '  , COALESCE(subq_4.is_instant, subq_9.is_instant, subq_14.is_instant)')                -->
-    </SelectSqlQueryToDataFrameTask>
+    </SelectSqlQueryToDataTableTask>
 </ExecutionPlan>
diff --git a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Databricks/test_joined_plan__ep_0.xml b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Databricks/test_joined_plan__ep_0.xml
index c46593dada..f231dbcccd 100644
--- a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Databricks/test_joined_plan__ep_0.xml
+++ b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Databricks/test_joined_plan__ep_0.xml
@@ -1,5 +1,5 @@
 <ExecutionPlan>
-    <SelectSqlQueryToDataFrameTask>
+    <SelectSqlQueryToDataTableTask>
         <!-- description = 'Run a query and write the results to a data frame' -->
         <!-- node_id = NodeId(id_str='rsq_0') -->
         <!-- sql_query =                                                                         -->
@@ -28,5 +28,5 @@
         <!--    'GROUP BY\n'                                                                     -->
         <!--    '  subq_2.is_instant\n'                                                          -->
         <!--    '  , listings_latest_src_28000.country')                                         -->
-    </SelectSqlQueryToDataFrameTask>
+    </SelectSqlQueryToDataTableTask>
 </ExecutionPlan>
diff --git a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Databricks/test_multihop_joined_plan__ep_0.xml b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Databricks/test_multihop_joined_plan__ep_0.xml
index 7b5757bb91..03d2b9d006 100644
--- a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Databricks/test_multihop_joined_plan__ep_0.xml
+++ b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Databricks/test_multihop_joined_plan__ep_0.xml
@@ -1,5 +1,5 @@
 <ExecutionPlan>
-    <SelectSqlQueryToDataFrameTask>
+    <SelectSqlQueryToDataTableTask>
         <!-- description = 'Run a query and write the results to a data frame' -->
         <!-- node_id = NodeId(id_str='rsq_0') -->
         <!-- sql_query =                                                                                             -->
@@ -37,5 +37,5 @@
         <!--    '  )\n'                                                                                              -->
         <!--    'GROUP BY\n'                                                                                         -->
         <!--    '  subq_14.customer_id__customer_name')                                                              -->
-    </SelectSqlQueryToDataFrameTask>
+    </SelectSqlQueryToDataTableTask>
 </ExecutionPlan>
diff --git a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Databricks/test_small_combined_metrics_plan__ep_0.xml b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Databricks/test_small_combined_metrics_plan__ep_0.xml
index 691fa0fb6c..38ff24ffce 100644
--- a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Databricks/test_small_combined_metrics_plan__ep_0.xml
+++ b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Databricks/test_small_combined_metrics_plan__ep_0.xml
@@ -1,5 +1,5 @@
 <ExecutionPlan>
-    <SelectSqlQueryToDataFrameTask>
+    <SelectSqlQueryToDataTableTask>
         <!-- description = 'Run a query and write the results to a data frame' -->
         <!-- node_id = NodeId(id_str='rsq_0') -->
         <!-- sql_query =                                                                        -->
@@ -43,5 +43,5 @@
         <!--    '  subq_4.is_instant = subq_9.is_instant\n'                                     -->
         <!--    'GROUP BY\n'                                                                    -->
         <!--    '  COALESCE(subq_4.is_instant, subq_9.is_instant)')                             -->
-    </SelectSqlQueryToDataFrameTask>
+    </SelectSqlQueryToDataTableTask>
 </ExecutionPlan>
diff --git a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/DuckDB/test_combined_metrics_plan__ep_0.xml b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/DuckDB/test_combined_metrics_plan__ep_0.xml
index 30ef3132d1..16ed0e7902 100644
--- a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/DuckDB/test_combined_metrics_plan__ep_0.xml
+++ b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/DuckDB/test_combined_metrics_plan__ep_0.xml
@@ -1,5 +1,5 @@
 <ExecutionPlan>
-    <SelectSqlQueryToDataFrameTask>
+    <SelectSqlQueryToDataTableTask>
         <!-- description = 'Run a query and write the results to a data frame' -->
         <!-- node_id = NodeId(id_str='rsq_0') -->
         <!-- sql_query =                                                                                 -->
@@ -82,5 +82,5 @@
         <!--    'GROUP BY\n'                                                                             -->
         <!--    '  COALESCE(subq_4.ds__day, subq_9.ds__day, subq_14.ds__day)\n'                          -->
         <!--    '  , COALESCE(subq_4.is_instant, subq_9.is_instant, subq_14.is_instant)')                -->
-    </SelectSqlQueryToDataFrameTask>
+    </SelectSqlQueryToDataTableTask>
 </ExecutionPlan>
diff --git a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/DuckDB/test_joined_plan__ep_0.xml b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/DuckDB/test_joined_plan__ep_0.xml
index c46593dada..f231dbcccd 100644
--- a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/DuckDB/test_joined_plan__ep_0.xml
+++ b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/DuckDB/test_joined_plan__ep_0.xml
@@ -1,5 +1,5 @@
 <ExecutionPlan>
-    <SelectSqlQueryToDataFrameTask>
+    <SelectSqlQueryToDataTableTask>
         <!-- description = 'Run a query and write the results to a data frame' -->
         <!-- node_id = NodeId(id_str='rsq_0') -->
         <!-- sql_query =                                                                         -->
@@ -28,5 +28,5 @@
         <!--    'GROUP BY\n'                                                                     -->
         <!--    '  subq_2.is_instant\n'                                                          -->
         <!--    '  , listings_latest_src_28000.country')                                         -->
-    </SelectSqlQueryToDataFrameTask>
+    </SelectSqlQueryToDataTableTask>
 </ExecutionPlan>
diff --git a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/DuckDB/test_multihop_joined_plan__ep_0.xml b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/DuckDB/test_multihop_joined_plan__ep_0.xml
index 7b5757bb91..03d2b9d006 100644
--- a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/DuckDB/test_multihop_joined_plan__ep_0.xml
+++ b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/DuckDB/test_multihop_joined_plan__ep_0.xml
@@ -1,5 +1,5 @@
 <ExecutionPlan>
-    <SelectSqlQueryToDataFrameTask>
+    <SelectSqlQueryToDataTableTask>
         <!-- description = 'Run a query and write the results to a data frame' -->
         <!-- node_id = NodeId(id_str='rsq_0') -->
         <!-- sql_query =                                                                                             -->
@@ -37,5 +37,5 @@
         <!--    '  )\n'                                                                                              -->
         <!--    'GROUP BY\n'                                                                                         -->
         <!--    '  subq_14.customer_id__customer_name')                                                              -->
-    </SelectSqlQueryToDataFrameTask>
+    </SelectSqlQueryToDataTableTask>
 </ExecutionPlan>
diff --git a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/DuckDB/test_small_combined_metrics_plan__ep_0.xml b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/DuckDB/test_small_combined_metrics_plan__ep_0.xml
index 691fa0fb6c..38ff24ffce 100644
--- a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/DuckDB/test_small_combined_metrics_plan__ep_0.xml
+++ b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/DuckDB/test_small_combined_metrics_plan__ep_0.xml
@@ -1,5 +1,5 @@
 <ExecutionPlan>
-    <SelectSqlQueryToDataFrameTask>
+    <SelectSqlQueryToDataTableTask>
         <!-- description = 'Run a query and write the results to a data frame' -->
         <!-- node_id = NodeId(id_str='rsq_0') -->
         <!-- sql_query =                                                                        -->
@@ -43,5 +43,5 @@
         <!--    '  subq_4.is_instant = subq_9.is_instant\n'                                     -->
         <!--    'GROUP BY\n'                                                                    -->
         <!--    '  COALESCE(subq_4.is_instant, subq_9.is_instant)')                             -->
-    </SelectSqlQueryToDataFrameTask>
+    </SelectSqlQueryToDataTableTask>
 </ExecutionPlan>
diff --git a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Postgres/test_combined_metrics_plan__ep_0.xml b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Postgres/test_combined_metrics_plan__ep_0.xml
index 30ef3132d1..16ed0e7902 100644
--- a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Postgres/test_combined_metrics_plan__ep_0.xml
+++ b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Postgres/test_combined_metrics_plan__ep_0.xml
@@ -1,5 +1,5 @@
 <ExecutionPlan>
-    <SelectSqlQueryToDataFrameTask>
+    <SelectSqlQueryToDataTableTask>
         <!-- description = 'Run a query and write the results to a data frame' -->
         <!-- node_id = NodeId(id_str='rsq_0') -->
         <!-- sql_query =                                                                                 -->
@@ -82,5 +82,5 @@
         <!--    'GROUP BY\n'                                                                             -->
         <!--    '  COALESCE(subq_4.ds__day, subq_9.ds__day, subq_14.ds__day)\n'                          -->
         <!--    '  , COALESCE(subq_4.is_instant, subq_9.is_instant, subq_14.is_instant)')                -->
-    </SelectSqlQueryToDataFrameTask>
+    </SelectSqlQueryToDataTableTask>
 </ExecutionPlan>
diff --git a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Postgres/test_joined_plan__ep_0.xml b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Postgres/test_joined_plan__ep_0.xml
index c46593dada..f231dbcccd 100644
--- a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Postgres/test_joined_plan__ep_0.xml
+++ b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Postgres/test_joined_plan__ep_0.xml
@@ -1,5 +1,5 @@
 <ExecutionPlan>
-    <SelectSqlQueryToDataFrameTask>
+    <SelectSqlQueryToDataTableTask>
         <!-- description = 'Run a query and write the results to a data frame' -->
         <!-- node_id = NodeId(id_str='rsq_0') -->
         <!-- sql_query =                                                                         -->
@@ -28,5 +28,5 @@
         <!--    'GROUP BY\n'                                                                     -->
         <!--    '  subq_2.is_instant\n'                                                          -->
         <!--    '  , listings_latest_src_28000.country')                                         -->
-    </SelectSqlQueryToDataFrameTask>
+    </SelectSqlQueryToDataTableTask>
 </ExecutionPlan>
diff --git a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Postgres/test_multihop_joined_plan__ep_0.xml b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Postgres/test_multihop_joined_plan__ep_0.xml
index 7b5757bb91..03d2b9d006 100644
--- a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Postgres/test_multihop_joined_plan__ep_0.xml
+++ b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Postgres/test_multihop_joined_plan__ep_0.xml
@@ -1,5 +1,5 @@
 <ExecutionPlan>
-    <SelectSqlQueryToDataFrameTask>
+    <SelectSqlQueryToDataTableTask>
         <!-- description = 'Run a query and write the results to a data frame' -->
         <!-- node_id = NodeId(id_str='rsq_0') -->
         <!-- sql_query =                                                                                             -->
@@ -37,5 +37,5 @@
         <!--    '  )\n'                                                                                              -->
         <!--    'GROUP BY\n'                                                                                         -->
         <!--    '  subq_14.customer_id__customer_name')                                                              -->
-    </SelectSqlQueryToDataFrameTask>
+    </SelectSqlQueryToDataTableTask>
 </ExecutionPlan>
diff --git a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Postgres/test_small_combined_metrics_plan__ep_0.xml b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Postgres/test_small_combined_metrics_plan__ep_0.xml
index 691fa0fb6c..38ff24ffce 100644
--- a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Postgres/test_small_combined_metrics_plan__ep_0.xml
+++ b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Postgres/test_small_combined_metrics_plan__ep_0.xml
@@ -1,5 +1,5 @@
 <ExecutionPlan>
-    <SelectSqlQueryToDataFrameTask>
+    <SelectSqlQueryToDataTableTask>
         <!-- description = 'Run a query and write the results to a data frame' -->
         <!-- node_id = NodeId(id_str='rsq_0') -->
         <!-- sql_query =                                                                        -->
@@ -43,5 +43,5 @@
         <!--    '  subq_4.is_instant = subq_9.is_instant\n'                                     -->
         <!--    'GROUP BY\n'                                                                    -->
         <!--    '  COALESCE(subq_4.is_instant, subq_9.is_instant)')                             -->
-    </SelectSqlQueryToDataFrameTask>
+    </SelectSqlQueryToDataTableTask>
 </ExecutionPlan>
diff --git a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Redshift/test_combined_metrics_plan__ep_0.xml b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Redshift/test_combined_metrics_plan__ep_0.xml
index 30ef3132d1..16ed0e7902 100644
--- a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Redshift/test_combined_metrics_plan__ep_0.xml
+++ b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Redshift/test_combined_metrics_plan__ep_0.xml
@@ -1,5 +1,5 @@
 <ExecutionPlan>
-    <SelectSqlQueryToDataFrameTask>
+    <SelectSqlQueryToDataTableTask>
         <!-- description = 'Run a query and write the results to a data frame' -->
         <!-- node_id = NodeId(id_str='rsq_0') -->
         <!-- sql_query =                                                                                 -->
@@ -82,5 +82,5 @@
         <!--    'GROUP BY\n'                                                                             -->
         <!--    '  COALESCE(subq_4.ds__day, subq_9.ds__day, subq_14.ds__day)\n'                          -->
         <!--    '  , COALESCE(subq_4.is_instant, subq_9.is_instant, subq_14.is_instant)')                -->
-    </SelectSqlQueryToDataFrameTask>
+    </SelectSqlQueryToDataTableTask>
 </ExecutionPlan>
diff --git a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Redshift/test_joined_plan__ep_0.xml b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Redshift/test_joined_plan__ep_0.xml
index c46593dada..f231dbcccd 100644
--- a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Redshift/test_joined_plan__ep_0.xml
+++ b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Redshift/test_joined_plan__ep_0.xml
@@ -1,5 +1,5 @@
 <ExecutionPlan>
-    <SelectSqlQueryToDataFrameTask>
+    <SelectSqlQueryToDataTableTask>
         <!-- description = 'Run a query and write the results to a data frame' -->
         <!-- node_id = NodeId(id_str='rsq_0') -->
         <!-- sql_query =                                                                         -->
@@ -28,5 +28,5 @@
         <!--    'GROUP BY\n'                                                                     -->
         <!--    '  subq_2.is_instant\n'                                                          -->
         <!--    '  , listings_latest_src_28000.country')                                         -->
-    </SelectSqlQueryToDataFrameTask>
+    </SelectSqlQueryToDataTableTask>
 </ExecutionPlan>
diff --git a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Redshift/test_multihop_joined_plan__ep_0.xml b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Redshift/test_multihop_joined_plan__ep_0.xml
index 7b5757bb91..03d2b9d006 100644
--- a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Redshift/test_multihop_joined_plan__ep_0.xml
+++ b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Redshift/test_multihop_joined_plan__ep_0.xml
@@ -1,5 +1,5 @@
 <ExecutionPlan>
-    <SelectSqlQueryToDataFrameTask>
+    <SelectSqlQueryToDataTableTask>
         <!-- description = 'Run a query and write the results to a data frame' -->
         <!-- node_id = NodeId(id_str='rsq_0') -->
         <!-- sql_query =                                                                                             -->
@@ -37,5 +37,5 @@
         <!--    '  )\n'                                                                                              -->
         <!--    'GROUP BY\n'                                                                                         -->
         <!--    '  subq_14.customer_id__customer_name')                                                              -->
-    </SelectSqlQueryToDataFrameTask>
+    </SelectSqlQueryToDataTableTask>
 </ExecutionPlan>
diff --git a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Redshift/test_small_combined_metrics_plan__ep_0.xml b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Redshift/test_small_combined_metrics_plan__ep_0.xml
index 691fa0fb6c..38ff24ffce 100644
--- a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Redshift/test_small_combined_metrics_plan__ep_0.xml
+++ b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Redshift/test_small_combined_metrics_plan__ep_0.xml
@@ -1,5 +1,5 @@
 <ExecutionPlan>
-    <SelectSqlQueryToDataFrameTask>
+    <SelectSqlQueryToDataTableTask>
         <!-- description = 'Run a query and write the results to a data frame' -->
         <!-- node_id = NodeId(id_str='rsq_0') -->
         <!-- sql_query =                                                                        -->
@@ -43,5 +43,5 @@
         <!--    '  subq_4.is_instant = subq_9.is_instant\n'                                     -->
         <!--    'GROUP BY\n'                                                                    -->
         <!--    '  COALESCE(subq_4.is_instant, subq_9.is_instant)')                             -->
-    </SelectSqlQueryToDataFrameTask>
+    </SelectSqlQueryToDataTableTask>
 </ExecutionPlan>
diff --git a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Snowflake/test_combined_metrics_plan__ep_0.xml b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Snowflake/test_combined_metrics_plan__ep_0.xml
index 30ef3132d1..16ed0e7902 100644
--- a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Snowflake/test_combined_metrics_plan__ep_0.xml
+++ b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Snowflake/test_combined_metrics_plan__ep_0.xml
@@ -1,5 +1,5 @@
 <ExecutionPlan>
-    <SelectSqlQueryToDataFrameTask>
+    <SelectSqlQueryToDataTableTask>
         <!-- description = 'Run a query and write the results to a data frame' -->
         <!-- node_id = NodeId(id_str='rsq_0') -->
         <!-- sql_query =                                                                                 -->
@@ -82,5 +82,5 @@
         <!--    'GROUP BY\n'                                                                             -->
         <!--    '  COALESCE(subq_4.ds__day, subq_9.ds__day, subq_14.ds__day)\n'                          -->
         <!--    '  , COALESCE(subq_4.is_instant, subq_9.is_instant, subq_14.is_instant)')                -->
-    </SelectSqlQueryToDataFrameTask>
+    </SelectSqlQueryToDataTableTask>
 </ExecutionPlan>
diff --git a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Snowflake/test_joined_plan__ep_0.xml b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Snowflake/test_joined_plan__ep_0.xml
index c46593dada..f231dbcccd 100644
--- a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Snowflake/test_joined_plan__ep_0.xml
+++ b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Snowflake/test_joined_plan__ep_0.xml
@@ -1,5 +1,5 @@
 <ExecutionPlan>
-    <SelectSqlQueryToDataFrameTask>
+    <SelectSqlQueryToDataTableTask>
         <!-- description = 'Run a query and write the results to a data frame' -->
         <!-- node_id = NodeId(id_str='rsq_0') -->
         <!-- sql_query =                                                                         -->
@@ -28,5 +28,5 @@
         <!--    'GROUP BY\n'                                                                     -->
         <!--    '  subq_2.is_instant\n'                                                          -->
         <!--    '  , listings_latest_src_28000.country')                                         -->
-    </SelectSqlQueryToDataFrameTask>
+    </SelectSqlQueryToDataTableTask>
 </ExecutionPlan>
diff --git a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Snowflake/test_multihop_joined_plan__ep_0.xml b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Snowflake/test_multihop_joined_plan__ep_0.xml
index 7b5757bb91..03d2b9d006 100644
--- a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Snowflake/test_multihop_joined_plan__ep_0.xml
+++ b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Snowflake/test_multihop_joined_plan__ep_0.xml
@@ -1,5 +1,5 @@
 <ExecutionPlan>
-    <SelectSqlQueryToDataFrameTask>
+    <SelectSqlQueryToDataTableTask>
         <!-- description = 'Run a query and write the results to a data frame' -->
         <!-- node_id = NodeId(id_str='rsq_0') -->
         <!-- sql_query =                                                                                             -->
@@ -37,5 +37,5 @@
         <!--    '  )\n'                                                                                              -->
         <!--    'GROUP BY\n'                                                                                         -->
         <!--    '  subq_14.customer_id__customer_name')                                                              -->
-    </SelectSqlQueryToDataFrameTask>
+    </SelectSqlQueryToDataTableTask>
 </ExecutionPlan>
diff --git a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Snowflake/test_small_combined_metrics_plan__ep_0.xml b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Snowflake/test_small_combined_metrics_plan__ep_0.xml
index 691fa0fb6c..38ff24ffce 100644
--- a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Snowflake/test_small_combined_metrics_plan__ep_0.xml
+++ b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Snowflake/test_small_combined_metrics_plan__ep_0.xml
@@ -1,5 +1,5 @@
 <ExecutionPlan>
-    <SelectSqlQueryToDataFrameTask>
+    <SelectSqlQueryToDataTableTask>
         <!-- description = 'Run a query and write the results to a data frame' -->
         <!-- node_id = NodeId(id_str='rsq_0') -->
         <!-- sql_query =                                                                        -->
@@ -43,5 +43,5 @@
         <!--    '  subq_4.is_instant = subq_9.is_instant\n'                                     -->
         <!--    'GROUP BY\n'                                                                    -->
         <!--    '  COALESCE(subq_4.is_instant, subq_9.is_instant)')                             -->
-    </SelectSqlQueryToDataFrameTask>
+    </SelectSqlQueryToDataTableTask>
 </ExecutionPlan>
diff --git a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Trino/test_combined_metrics_plan__ep_0.xml b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Trino/test_combined_metrics_plan__ep_0.xml
index 30ef3132d1..16ed0e7902 100644
--- a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Trino/test_combined_metrics_plan__ep_0.xml
+++ b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Trino/test_combined_metrics_plan__ep_0.xml
@@ -1,5 +1,5 @@
 <ExecutionPlan>
-    <SelectSqlQueryToDataFrameTask>
+    <SelectSqlQueryToDataTableTask>
         <!-- description = 'Run a query and write the results to a data frame' -->
         <!-- node_id = NodeId(id_str='rsq_0') -->
         <!-- sql_query =                                                                                 -->
@@ -82,5 +82,5 @@
         <!--    'GROUP BY\n'                                                                             -->
         <!--    '  COALESCE(subq_4.ds__day, subq_9.ds__day, subq_14.ds__day)\n'                          -->
         <!--    '  , COALESCE(subq_4.is_instant, subq_9.is_instant, subq_14.is_instant)')                -->
-    </SelectSqlQueryToDataFrameTask>
+    </SelectSqlQueryToDataTableTask>
 </ExecutionPlan>
diff --git a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Trino/test_joined_plan__ep_0.xml b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Trino/test_joined_plan__ep_0.xml
index c46593dada..f231dbcccd 100644
--- a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Trino/test_joined_plan__ep_0.xml
+++ b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Trino/test_joined_plan__ep_0.xml
@@ -1,5 +1,5 @@
 <ExecutionPlan>
-    <SelectSqlQueryToDataFrameTask>
+    <SelectSqlQueryToDataTableTask>
         <!-- description = 'Run a query and write the results to a data frame' -->
         <!-- node_id = NodeId(id_str='rsq_0') -->
         <!-- sql_query =                                                                         -->
@@ -28,5 +28,5 @@
         <!--    'GROUP BY\n'                                                                     -->
         <!--    '  subq_2.is_instant\n'                                                          -->
         <!--    '  , listings_latest_src_28000.country')                                         -->
-    </SelectSqlQueryToDataFrameTask>
+    </SelectSqlQueryToDataTableTask>
 </ExecutionPlan>
diff --git a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Trino/test_multihop_joined_plan__ep_0.xml b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Trino/test_multihop_joined_plan__ep_0.xml
index 7b5757bb91..03d2b9d006 100644
--- a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Trino/test_multihop_joined_plan__ep_0.xml
+++ b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Trino/test_multihop_joined_plan__ep_0.xml
@@ -1,5 +1,5 @@
 <ExecutionPlan>
-    <SelectSqlQueryToDataFrameTask>
+    <SelectSqlQueryToDataTableTask>
         <!-- description = 'Run a query and write the results to a data frame' -->
         <!-- node_id = NodeId(id_str='rsq_0') -->
         <!-- sql_query =                                                                                             -->
@@ -37,5 +37,5 @@
         <!--    '  )\n'                                                                                              -->
         <!--    'GROUP BY\n'                                                                                         -->
         <!--    '  subq_14.customer_id__customer_name')                                                              -->
-    </SelectSqlQueryToDataFrameTask>
+    </SelectSqlQueryToDataTableTask>
 </ExecutionPlan>
diff --git a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Trino/test_small_combined_metrics_plan__ep_0.xml b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Trino/test_small_combined_metrics_plan__ep_0.xml
index 691fa0fb6c..38ff24ffce 100644
--- a/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Trino/test_small_combined_metrics_plan__ep_0.xml
+++ b/tests_metricflow/snapshots/test_dataflow_to_execution.py/ExecutionPlan/Trino/test_small_combined_metrics_plan__ep_0.xml
@@ -1,5 +1,5 @@
 <ExecutionPlan>
-    <SelectSqlQueryToDataFrameTask>
+    <SelectSqlQueryToDataTableTask>
         <!-- description = 'Run a query and write the results to a data frame' -->
         <!-- node_id = NodeId(id_str='rsq_0') -->
         <!-- sql_query =                                                                        -->
@@ -43,5 +43,5 @@
         <!--    '  subq_4.is_instant = subq_9.is_instant\n'                                     -->
         <!--    'GROUP BY\n'                                                                    -->
         <!--    '  COALESCE(subq_4.is_instant, subq_9.is_instant)')                             -->
-    </SelectSqlQueryToDataFrameTask>
+    </SelectSqlQueryToDataTableTask>
 </ExecutionPlan>