exception

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

Author: tchow-zlai

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

@@ -52,7 +52,12 @@ case class GCS(project: String, sourceUri: String, fileFormat: String) extends F
     val partitions = partitionSpec.partitions.map(_.values)
 
     val deserializer =
-      Encoders.row(partitionColumns).asInstanceOf[ExpressionEncoder[Row]].resolveAndBind().createDeserializer()
+      try {
+        Encoders.row(partitionColumns).asInstanceOf[ExpressionEncoder[Row]].resolveAndBind().createDeserializer()
+      } catch {
+        case e: Exception =>
+          throw new RuntimeException(s"Failed to create deserializer for partition columns: ${e.getMessage}", e)
+      }
 
     val roundTripped = sparkSession
       .createDataFrame(sparkSession.sparkContext.parallelize(partitions.map(deserializer)), partitionColumns)