Skip to content

Commit a726012

Browse files
committed
changes
1 parent bb8a2d1 commit a726012

File tree

1 file changed

+9
-1
lines changed

1 file changed

+9
-1
lines changed

tests/ast/decoder.py

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -987,6 +987,9 @@ def decode_expr(self, expr: proto.Expr, **kwargs) -> Any:
987987
return call_table_function(
988988
fn_name, *pos_args, **named_args
989989
)
990+
991+
case "stored_procedure":
992+
return self.session.call(fn_name, *pos_args, **named_args)
990993
case _:
991994
raise ValueError(
992995
"Unknown function reference type: %s"
@@ -2813,8 +2816,13 @@ def decode_expr(self, expr: proto.Expr, **kwargs) -> Any:
28132816
return_type = self.decode_data_type_expr(
28142817
expr.stored_procedure.return_type
28152818
)
2819+
name = None
2820+
if expr.stored_procedure.HasField("name"):
2821+
name = self.decode_name_expr(expr.stored_procedure.name)
2822+
28162823
ret_sproc = sproc(
2817-
lambda *args: None,
2824+
self.session.sproc._registry[registered_object_name],
2825+
name=name,
28182826
return_type=return_type,
28192827
input_types=input_types,
28202828
execute_as=execute_as,

0 commit comments

Comments
 (0)