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)