passing tests

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

Author: tchow-zlai

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

@@ -118,10 +118,13 @@ class DelegatingBigQueryMetastoreCatalog extends TableCatalog with SupportsNames
 
   override def loadTable(rawIdent: Identifier): Table = {
     // Remove the catalog segment. We've already consumed it, now it's time to figure out the namespace.
-    val identNoCatalog = Identifier.of(rawIdent.namespace.flatMap(_.split("\\.")).toList match {
-      case catalog :: namespace :: Nil => Array(namespace)
-      case namespace :: Nil => Array(namespace)
-    }, rawIdent.name)
+    val identNoCatalog = Identifier.of(
+      rawIdent.namespace.flatMap(_.split("\\.")).toList match {
+        case catalog :: namespace :: Nil => Array(namespace)
+        case namespace :: Nil            => Array(namespace)
+      },
+      rawIdent.name
+    )
     Try {
       val icebergSparkTable = icebergCatalog.loadTable(identNoCatalog)
       DelegatingTable(icebergSparkTable,

spark/src/test/scala/ai/chronon/spark/test/TableUtilsTest.scala

@@ -26,6 +26,7 @@ import org.junit.Assert.{assertEquals, assertTrue}
 import org.scalatest.flatspec.AnyFlatSpec
 
 import ai.chronon.spark.format.FormatProvider
+import ai.chronon.spark.format.DefaultFormatProvider
 import org.apache.spark.sql.catalyst.parser.ParseException
 
 import scala.util.Try
@@ -644,7 +645,6 @@ class TableUtilsTest extends AnyFlatSpec {
   }
 
   it should "test catalog detection" in {
-    import ai.chronon.spark.format.DefaultFormatProvider
     val fp = FormatProvider.from(spark).asInstanceOf[DefaultFormatProvider]
     assertEquals("catalogA", fp.getCatalog("catalogA.foo.bar"))
     assertEquals("catalogA", fp.getCatalog("`catalogA`.foo.bar"))