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 index 910d4477a3..b9b2ad6a54 100644 --- 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)))