From bc3cec68d0fa4428dd6c4d1e0b672ec6434c5cc2 Mon Sep 17 00:00:00 2001 From: Sarah Yurick Date: Thu, 11 Aug 2022 16:17:02 -0700 Subject: [PATCH] initial fix --- dask_sql/physical/rex/core/call.py | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/dask_sql/physical/rex/core/call.py b/dask_sql/physical/rex/core/call.py index efce50df8..9d3442df0 100644 --- a/dask_sql/physical/rex/core/call.py +++ b/dask_sql/physical/rex/core/call.py @@ -133,7 +133,13 @@ def reduce(self, *operands, **kwargs): ) ): operands = tuple(map(as_timelike, operands)) - return reduce(partial(self.operation, **kwargs), operands) + try: + return reduce(partial(self.operation, **kwargs), operands) + except ValueError: + return reduce( + partial(self.operation, **kwargs), + (operands[0], float(operands[1][operands[1].columns[0]].loc[0].compute())) + ) else: return self.unary_operation(*operands, **kwargs)