From 61bc5f9bb35efc396fdc473955b145e96f9f7810 Mon Sep 17 00:00:00 2001 From: Donghan Zhang Date: Fri, 23 Feb 2024 16:38:31 -0800 Subject: [PATCH] format --- spark/src/main/scala/ai/chronon/spark/JoinBase.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/spark/src/main/scala/ai/chronon/spark/JoinBase.scala b/spark/src/main/scala/ai/chronon/spark/JoinBase.scala index f59536087..e6fdafec7 100644 --- a/spark/src/main/scala/ai/chronon/spark/JoinBase.scala +++ b/spark/src/main/scala/ai/chronon/spark/JoinBase.scala @@ -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 {