Fix the test to create or replace

dbt-labs · Nov 18, 2020 · b5b6936 · b5b6936
1 parent 880db89
commit b5b6936
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/test/unit/test_macros.py b/test/unit/test_macros.py
@@ -41,7 +41,7 @@ def test_macros_create_table_as_file_format(self):
 
         self.config['file_format'] = 'delta'
         sql = self.__run_macro(template, 'spark__create_table_as', False, 'my_table', 'select 1').strip()
-        self.assertEqual(sql, "create table my_table using delta as select 1")
+        self.assertEqual(sql, "create or replace table my_table using delta as select 1")
 
     def test_macros_create_table_as_partition(self):
         template = self.__get_template('adapters.sql')
@@ -103,5 +103,5 @@ def test_macros_create_table_as_all(self):
         sql = self.__run_macro(template, 'spark__create_table_as', False, 'my_table', 'select 1').strip()
         self.assertEqual(
             sql,
-            "create table my_table using delta partitioned by (partition_1,partition_2) clustered by (cluster_1,cluster_2) into 1 buckets location '/mnt/root/my_table' comment 'Description Test' as select 1"
+            "create or replace table my_table using delta partitioned by (partition_1,partition_2) clustered by (cluster_1,cluster_2) into 1 buckets location '/mnt/root/my_table' comment 'Description Test' as select 1"
         )