Skip to content

Commit c0cdf55

Browse files
authored
fix: Fix JSON type handling (#19)
1 parent 2a5996b commit c0cdf55

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

cloudquery/sdk/scalar/scalar_factory.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@
77
from .date64 import Date64
88
from .float import Float
99
from .int import Int
10+
from .json import JSON
1011
from .list import List
1112
from .scalar import ScalarInvalidTypeError
1213
from .string import String
@@ -89,6 +90,6 @@ def new_scalar(self, dt: pa.DataType):
8990
elif dt == UUIDType():
9091
return UUID()
9192
elif dt == JSONType():
92-
return String()
93+
return JSON()
9394
else:
9495
raise ScalarInvalidTypeError("Invalid type {} for scalar".format(dt))

cloudquery/sdk/scalar/string.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,4 @@
11
from cloudquery.sdk.scalar import Scalar, ScalarInvalidTypeError
2-
from .scalar import NULL_VALUE
32

43

54
class String(Scalar):

0 commit comments

Comments
 (0)