@@ -669,7 +669,7 @@ def test_replace_table_catalog_support(
669669
670670 adapter .replace_query (
671671 table_name = "." .join ([catalog_name , "schema" , "test_table" ]),
672- query_or_df = parse_one ("SELECT 1 AS col" ),
672+ query_or_df = t . cast ( exp . Query , parse_one ("SELECT 1 AS col" ) ),
673673 )
674674
675675 sql_calls = to_sql_calls (adapter )
@@ -705,7 +705,7 @@ def test_insert_overwrite_time_partition_hive(
705705
706706 adapter .insert_overwrite_by_time_partition (
707707 table_name = "." .join (["my_catalog" , "schema" , "test_table" ]),
708- query_or_df = parse_one ("SELECT a, b FROM tbl" ),
708+ query_or_df = t . cast ( exp . Query , parse_one ("SELECT a, b FROM tbl" ) ),
709709 start = "2022-01-01" ,
710710 end = "2022-01-02" ,
711711 time_column = "b" ,
@@ -743,7 +743,7 @@ def test_insert_overwrite_time_partition_iceberg(
743743
744744 adapter .insert_overwrite_by_time_partition (
745745 table_name = "." .join (["my_catalog" , "schema" , "test_table" ]),
746- query_or_df = parse_one ("SELECT a, b FROM tbl" ),
746+ query_or_df = t . cast ( exp . Query , parse_one ("SELECT a, b FROM tbl" ) ),
747747 start = "2022-01-01" ,
748748 end = "2022-01-02" ,
749749 time_column = "b" ,
0 commit comments