Skip to content

Commit dd5e111

Browse files
committed
Correct class names and internal attr
1 parent 7ec4148 commit dd5e111

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

python/datafusion/context.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -810,11 +810,11 @@ def register_dataset(self, name: str, dataset: pyarrow.dataset.Dataset) -> None:
810810

811811
def register_udf(self, udf: ScalarUDF) -> None:
812812
"""Register a user-defined function (UDF) with the context."""
813-
self.ctx.register_udf(udf.udf)
813+
self.ctx.register_udf(udf._udf)
814814

815815
def register_udaf(self, udaf: AggregateUDF) -> None:
816816
"""Register a user-defined aggregation function (UDAF) with the context."""
817-
self.ctx.register_udaf(udaf)
817+
self.ctx.register_udaf(udaf._udaf)
818818

819819
def catalog(self, name: str = "datafusion") -> Catalog:
820820
"""Retrieve a catalog by name."""

0 commit comments

Comments
 (0)