Fix in the aggregate function with alias (finos#90)

Fix alias name when is added in the aggregate function for the column
Snowflake-Labs · Dec 13, 2023 · c242992 · c242992
1 parent a5deb05
commit c242992
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/Morphir/Snowpark/AggregateMapping.elm b/src/Morphir/Snowpark/AggregateMapping.elm
@@ -27,10 +27,10 @@ processAggregateLambdaBody body mapValue ctx =
             [Scala.ArgValue Nothing (Scala.Literal (Scala.StringLit "To Do - Processing Other"))]
 
 concatFunctions : Constants.VariableInformation -> List Scala.ArgValue
-concatFunctions (aliasList, functions) = 
+concatFunctions (aliasList, functions) =
     functions 
         |> List.map processList
-            |> List.map2 joinWithAlias aliasList
+            |> List.map2 joinWithAlias (List.tail aliasList |> Maybe.withDefault [])
 
 processList : (String, Scala.Value) -> Scala.Value
 processList (funcName, columnName) =