Some missing options in SnowflakeIO (#5550)

spotify · Jan 23, 2025 · d5d20ad · d5d20ad
1 parent db7b14e
commit d5d20ad
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/scio-snowflake/src/main/scala/com/spotify/scio/snowflake/SnowflakeIO.scala b/scio-snowflake/src/main/scala/com/spotify/scio/snowflake/SnowflakeIO.scala
@@ -210,6 +210,7 @@ final case class SnowflakeTable[T](connectionOptions: SnowflakeConnectionOptions
       .pipe(w => Option(params.flushTimeLimit).fold(w)(w.withFlushTimeLimit))
       .pipe(w => Option(params.quotationMark).fold(w)(w.withQuotationMark))
       .pipe(w => Option(params.storageIntegrationName).fold(w)(w.withStorageIntegrationName))
+      .pipe(w => Option(params.tableSchema).fold(w)(w.withTableSchema))
       .withStagingBucketName(tempDirectory)
       .withUserDataMapper(userDataMapper)
       .pipe(w => Option(params.configOverride).fold(w)(_(w)))