diff --git a/src/main/scala/com/metabolic/data/core/services/athena/AthenaAction.scala b/src/main/scala/com/metabolic/data/core/services/athena/AthenaAction.scala
index 0d5e386..a888b0e 100644
--- a/src/main/scala/com/metabolic/data/core/services/athena/AthenaAction.scala
+++ b/src/main/scala/com/metabolic/data/core/services/athena/AthenaAction.scala
@@ -30,7 +30,7 @@ class AthenaAction extends AfterAction with Logging {
               ConfigUtilsService.getTablePrefix(options.namespaces, s3Path)
             val tableName = prefix + ConfigUtilsService.getTableName(config)
             athena.dropView(dbName, tableName)
-            athena.createDeltaTable(dbName, tableName, s3Path)
+            athena.createDeltaTable(dbName, tableName, s3Path, recreate = true)
 
           case _ =>
             logger.warn(f"After Action: Skipping $name for ${config.name} as it is not a DeltaSink")
diff --git a/src/main/scala/com/metabolic/data/core/services/athena/AthenaCatalogueService.scala b/src/main/scala/com/metabolic/data/core/services/athena/AthenaCatalogueService.scala
index 7c02c24..92ff1e4 100644
--- a/src/main/scala/com/metabolic/data/core/services/athena/AthenaCatalogueService.scala
+++ b/src/main/scala/com/metabolic/data/core/services/athena/AthenaCatalogueService.scala
@@ -28,7 +28,7 @@ class AthenaCatalogueService(implicit val region: Regions) extends Logging {
   private def dropTableStatement(dbName: String, tableName: String) = {
 
     s"DROP TABLE IF EXISTS " +
-      s"$dbName.$tableName"
+      s"`$dbName`.`$tableName`"
   }
 
   def dropView(dbName: String, viewName: String) = {