Skip to content

Commit

Permalink
format
Browse files Browse the repository at this point in the history
  • Loading branch information
Donghan Zhang committed Feb 24, 2024
1 parent 90243c5 commit 61bc5f9
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion spark/src/main/scala/ai/chronon/spark/JoinBase.scala
Original file line number Diff line number Diff line change
Expand Up @@ -361,7 +361,8 @@ abstract class JoinBase(joinConf: api.Join,
// set autoExpand = true to ensure backward compatibility due to column ordering changes
val finalDf = computeRange(leftDfInRange, range, bootstrapInfo)
if (selectedJoinParts.isDefined) {
assert(finalDf.isEmpty, "The arg `selectedJoinParts` is defined, so no final join is required. `finalDf` should be empty")
assert(finalDf.isEmpty,
"The arg `selectedJoinParts` is defined, so no final join is required. `finalDf` should be empty")
logger.info(s"Skipping writing to the output table for range: ${range.toString} $progress")
return None
} else {
Expand Down

0 comments on commit 61bc5f9

Please sign in to comment.