@@ -882,17 +882,20 @@ class FlattenFields(BaseModel):
882
882
883
883
884
884
class KeyTransformation (BaseModel ):
885
- type : Literal ["KeyTransformation" ]
886
- prefix : Optional [str ] = Field (
885
+ prefix : Optional [Union [str , None ]] = Field (
887
886
None ,
888
887
description = "Prefix to add for object keys. If not provided original keys remain unchanged." ,
889
- examples = ["flattened_" ],
888
+ examples = [
889
+ "flattened_" ,
890
+ ],
890
891
title = "Key Prefix" ,
891
892
)
892
- suffix : Optional [str ] = Field (
893
+ suffix : Optional [Union [ str , None ] ] = Field (
893
894
None ,
894
895
description = "Suffix to add for object keys. If not provided original keys remain unchanged." ,
895
- examples = ["_flattened" ],
896
+ examples = [
897
+ "_flattened" ,
898
+ ],
896
899
title = "Key Suffix" ,
897
900
)
898
901
@@ -915,7 +918,7 @@ class DpathFlattenFields(BaseModel):
915
918
description = "Whether to replace the origin record or not. Default is False." ,
916
919
title = "Replace Origin Record" ,
917
920
)
918
- key_transformation : Optional [KeyTransformation ] = Field (
921
+ key_transformation : Optional [Union [ KeyTransformation , None ] ] = Field (
919
922
None ,
920
923
description = "Transformation for object keys. If not provided, original key will be used." ,
921
924
title = "Key transformation" ,
@@ -2637,4 +2640,4 @@ class DynamicDeclarativeStream(BaseModel):
2637
2640
ParentStreamConfig .update_forward_refs ()
2638
2641
PropertiesFromEndpoint .update_forward_refs ()
2639
2642
SimpleRetriever .update_forward_refs ()
2640
- AsyncRetriever .update_forward_refs ()
2643
+ AsyncRetriever .update_forward_refs ()
0 commit comments