updates

Co-authored-by: Thomas Chow <[email protected]>

Author: tchow-zlai

cloud_gcp/src/main/scala/ai/chronon/integrations/cloud_gcp/GcpFormatProvider.scala

@@ -33,8 +33,8 @@ case class GcpFormatProvider(sparkSession: SparkSession) extends FormatProvider
 
   override def writeFormat(table: String): Format = {
     val tableId = BigQueryUtil.parseTableId(table)
-    assert(Option(tableId.getProject).isDefined, s"project required for ${table}")
-    assert(Option(tableId.getDataset).isDefined, s"dataset required for ${table}")
+    assert(scala.Option(tableId.getProject).isDefined, s"project required for ${table}")
+    assert(scala.Option(tableId.getDataset).isDefined, s"dataset required for ${table}")
 
     val tu = TableUtils(sparkSession)
     val partitionColumnOption =
@@ -79,7 +79,7 @@ case class GcpFormatProvider(sparkSession: SparkSession) extends FormatProvider
     scala
       .Option(table)
       .map(getFormat)
-      .getOrElse(Option(btTableIdentifier.getProject).map(BigQueryFormat(_, Map.empty)).getOrElse(Hive))
+      .getOrElse(scala.Option(btTableIdentifier.getProject).map(BigQueryFormat(_, Map.empty)).getOrElse(Hive))
 
   }
 }

spark/src/main/scala/ai/chronon/spark/TableUtils.scala

@@ -125,7 +125,7 @@ class TableUtils(@transient val sparkSession: SparkSession) extends Serializable
       true
     } catch {
       case ex: Exception =>
-        logger.error(s"Couldn't load $tableName", ex)
+        logger.debug(s"Couldn't load $tableName", ex)
         false
     }
   }