Skip to content

Commit 66b2dc1

Browse files
left this out
Co-authored-by: Thomas Chow <[email protected]>
1 parent d11f540 commit 66b2dc1

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -592,7 +592,7 @@ class TableUtils(@transient val sparkSession: SparkSession) extends Serializable
592592
| ${rangeWheres.mkString(",\n ").green}
593593
|""".stripMargin)
594594

595-
var df = loadTable(table)
595+
var df = loadTable(table, rangeWheres)
596596

597597
if (selects.nonEmpty) df = df.selectExpr(selects: _*)
598598

0 commit comments

Comments
 (0)