@@ -67,10 +67,10 @@ class _BsonArrowTypes(enum.Enum):
67
67
68
68
69
69
class BSONExtensionScalar (ExtensionScalar ):
70
- def as_py (self ):
70
+ def as_py (self , * args , ** kwargs ):
71
71
if self .value is None :
72
72
return None
73
- return self ._bson_class (self .value .as_py ())
73
+ return self ._bson_class (self .value .as_py (* args , ** kwargs ))
74
74
75
75
76
76
class ObjectIdScalar (BSONExtensionScalar ):
@@ -101,10 +101,10 @@ def __arrow_ext_deserialize__(self, storage_type, serialized):
101
101
102
102
103
103
class Decimal128Scalar (ExtensionScalar ):
104
- def as_py (self ):
104
+ def as_py (self , * args , ** kwargs ):
105
105
if self .value is None :
106
106
return None
107
- return Decimal128 .from_bid (self .value .as_py ())
107
+ return Decimal128 .from_bid (self .value .as_py (* args , ** kwargs ))
108
108
109
109
110
110
class Decimal128Type (ExtensionType ):
@@ -131,11 +131,11 @@ def __arrow_ext_deserialize__(self, storage_type, serialized):
131
131
132
132
133
133
class BinaryScalar (ExtensionScalar ):
134
- def as_py (self ):
134
+ def as_py (self , * args , ** kwargs ):
135
135
value = self .value
136
136
if value is None :
137
137
return None
138
- return Binary (self .value .as_py (), self .type .subtype )
138
+ return Binary (self .value .as_py (* args , ** kwargs ), self .type .subtype )
139
139
140
140
141
141
class BinaryType (ExtensionType ):
0 commit comments