diff --git a/narwhals/_spark_like/expr.py b/narwhals/_spark_like/expr.py index d4b9907e3..18be20f7d 100644 --- a/narwhals/_spark_like/expr.py +++ b/narwhals/_spark_like/expr.py @@ -365,7 +365,9 @@ def _filter( ], ) query = reduce(operator.and_, predicates) - return F.explode(F.filter(F.array(_input), lambda _: query)) + return F.explode( + F.filter(F.array(_input), lambda _: query) + ) # TODO (unauthored): resolve PySparkValueError: [HIGHER_ORDER_FUNCTION_SHOULD_RETURN_COLUMN] Function `` should return Column, got SparkLikeExpr. return self._from_call( _filter,