SK-3118: flowvault Java-parity fixes + internal HTTP pool/concurrency defaults

Parity with the Java flowvault SDK:
- update(): send updateType to the API (was silently dropped). Wired the
  regenerated update endpoint's updateType through the controller, converting
  the public UpsertType enum to its wire value and omitting it when unset.
- Add typed DetokenizeResponseRecordMetadata for the metadata field on both
  unary and bulk detokenize responses (was an untyped dict).
- Rename public ColumnRedaction -> ColumnRedactions (matches Java; pre-release,
  no alias). Generated wire type untouched.
- Type update_type as UpsertType on UpdateRequest and UpsertOptions.

Internal HTTP tuning (not exposed via VaultConfig):
- httpx connection pool defaults: max_connections=100, max_keepalive_connections=100,
  keepalive_expiry=60s (was 20 / 5s) to reduce connection churn.
- Raise bulk insert/detokenize MAX_CONCURRENCY cap from 10 to 100.

Tests updated accordingly.

Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>

Author: saileshwar-skyflow

flowvault/skyflow/generated/rest/__init__.py

@@ -30,6 +30,7 @@
         TokenizeResponseObject,
         UniqueValue,
         UpdateRecordData,
+        UpdateRecordDataUpdateType,
         UpdateResponse,
         Upsert,
         UpsertUpdateType,
@@ -46,6 +47,7 @@
     from ._default_clients import DefaultAioHttpClient, DefaultAsyncHttpxClient
     from .client import AsyncSkyflowAuth, SkyflowAuth
     from .environment import SkyflowAuthEnvironment
+    from .records import UpdateRequestUpdateType
     from .version import __version__
 _dynamic_imports: typing.Dict[str, str] = {
     "AsyncSkyflowAuth": ".client",
@@ -82,6 +84,8 @@
     "UnauthorizedError": ".errors",
     "UniqueValue": ".types",
     "UpdateRecordData": ".types",
+    "UpdateRecordDataUpdateType": ".types",
+    "UpdateRequestUpdateType": ".records",
     "UpdateResponse": ".types",
     "Upsert": ".types",
     "UpsertUpdateType": ".types",
@@ -148,6 +152,8 @@ def __dir__():
     "UnauthorizedError",
     "UniqueValue",
     "UpdateRecordData",
+    "UpdateRecordDataUpdateType",
+    "UpdateRequestUpdateType",
     "UpdateResponse",
     "Upsert",
     "UpsertUpdateType",

flowvault/skyflow/generated/rest/core/client_wrapper.py

@@ -37,7 +37,7 @@ def get_headers(self) -> typing.Dict[str, str]:
             "X-Fern-Runtime": f"python/{platform.python_version()}",
             "X-Fern-Platform": f"{platform.system().lower()}/{platform.release()}",
             "X-Fern-SDK-Name": "skyflow.generated.rest",
-            "X-Fern-SDK-Version": "0.0.20",
+            "X-Fern-SDK-Version": "0.0.21",
             **(self.get_custom_headers() or {}),
         }
         token = self._get_token()

flowvault/skyflow/generated/rest/records/__init__.py

@@ -2,3 +2,33 @@
 
 # isort: skip_file
 
+import typing
+from importlib import import_module
+
+if typing.TYPE_CHECKING:
+    from .types import UpdateRequestUpdateType
+_dynamic_imports: typing.Dict[str, str] = {"UpdateRequestUpdateType": ".types"}
+
+
+def __getattr__(attr_name: str) -> typing.Any:
+    module_name = _dynamic_imports.get(attr_name)
+    if module_name is None:
+        raise AttributeError(f"No {attr_name} found in _dynamic_imports for module name -> {__name__}")
+    try:
+        module = import_module(module_name, __package__)
+        if module_name == f".{attr_name}":
+            return module
+        else:
+            return getattr(module, attr_name)
+    except ImportError as e:
+        raise ImportError(f"Failed to import {attr_name} from {module_name}: {e}") from e
+    except AttributeError as e:
+        raise AttributeError(f"Failed to get {attr_name} from {module_name}: {e}") from e
+
+
+def __dir__():
+    lazy_attrs = list(_dynamic_imports.keys())
+    return sorted(lazy_attrs)
+
+
+__all__ = ["UpdateRequestUpdateType"]

flowvault/skyflow/generated/rest/records/client.py

@@ -15,6 +15,7 @@
 from ..types.update_response import UpdateResponse
 from ..types.upsert import Upsert
 from .raw_client import AsyncRawRecordsClient, RawRecordsClient
+from .types.update_request_update_type import UpdateRequestUpdateType
 
 # this is used as the default value for optional parameters
 OMIT = typing.cast(typing.Any, ...)
@@ -264,6 +265,7 @@ def update_records(
         vault_id: str,
         table_name: str,
         records: typing.Sequence[UpdateRecordData],
+        update_type: typing.Optional[UpdateRequestUpdateType] = OMIT,
         request_options: typing.Optional[RequestOptions] = None,
     ) -> UpdateResponse:
         """
@@ -280,6 +282,9 @@ def update_records(
         records : typing.Sequence[UpdateRecordData]
             Data to update as a list of records.
 
+        update_type : typing.Optional[UpdateRequestUpdateType]
+            Type of update operation to perform.
+
         request_options : typing.Optional[RequestOptions]
             Request-specific configuration.
 
@@ -323,7 +328,11 @@ def update_records(
         )
         """
         _response = self._raw_client.update_records(
-            vault_id=vault_id, table_name=table_name, records=records, request_options=request_options
+            vault_id=vault_id,
+            table_name=table_name,
+            records=records,
+            update_type=update_type,
+            request_options=request_options,
         )
         return _response.data
 
@@ -596,6 +605,7 @@ async def update_records(
         vault_id: str,
         table_name: str,
         records: typing.Sequence[UpdateRecordData],
+        update_type: typing.Optional[UpdateRequestUpdateType] = OMIT,
         request_options: typing.Optional[RequestOptions] = None,
     ) -> UpdateResponse:
         """
@@ -612,6 +622,9 @@ async def update_records(
         records : typing.Sequence[UpdateRecordData]
             Data to update as a list of records.
 
+        update_type : typing.Optional[UpdateRequestUpdateType]
+            Type of update operation to perform.
+
         request_options : typing.Optional[RequestOptions]
             Request-specific configuration.
 
@@ -663,6 +676,10 @@ async def main() -> None:
         asyncio.run(main())
         """
         _response = await self._raw_client.update_records(
-            vault_id=vault_id, table_name=table_name, records=records, request_options=request_options
+            vault_id=vault_id,
+            table_name=table_name,
+            records=records,
+            update_type=update_type,
+            request_options=request_options,
         )
         return _response.data

flowvault/skyflow/generated/rest/records/raw_client.py

@@ -25,6 +25,7 @@
 from ..types.update_record_data import UpdateRecordData
 from ..types.update_response import UpdateResponse
 from ..types.upsert import Upsert
+from .types.update_request_update_type import UpdateRequestUpdateType
 from pydantic import ValidationError
 
 # this is used as the default value for optional parameters
@@ -400,6 +401,7 @@ def update_records(
         vault_id: str,
         table_name: str,
         records: typing.Sequence[UpdateRecordData],
+        update_type: typing.Optional[UpdateRequestUpdateType] = OMIT,
         request_options: typing.Optional[RequestOptions] = None,
     ) -> HttpResponse[UpdateResponse]:
         """
@@ -416,6 +418,9 @@ def update_records(
         records : typing.Sequence[UpdateRecordData]
             Data to update as a list of records.
 
+        update_type : typing.Optional[UpdateRequestUpdateType]
+            Type of update operation to perform.
+
         request_options : typing.Optional[RequestOptions]
             Request-specific configuration.
 
@@ -433,6 +438,7 @@ def update_records(
                 "records": convert_and_respect_annotation_metadata(
                     object_=records, annotation=typing.Sequence[UpdateRecordData], direction="write"
                 ),
+                "updateType": update_type,
             },
             headers={
                 "content-type": "application/json",
@@ -873,6 +879,7 @@ async def update_records(
         vault_id: str,
         table_name: str,
         records: typing.Sequence[UpdateRecordData],
+        update_type: typing.Optional[UpdateRequestUpdateType] = OMIT,
         request_options: typing.Optional[RequestOptions] = None,
     ) -> AsyncHttpResponse[UpdateResponse]:
         """
@@ -889,6 +896,9 @@ async def update_records(
         records : typing.Sequence[UpdateRecordData]
             Data to update as a list of records.
 
+        update_type : typing.Optional[UpdateRequestUpdateType]
+            Type of update operation to perform.
+
         request_options : typing.Optional[RequestOptions]
             Request-specific configuration.
 
@@ -906,6 +916,7 @@ async def update_records(
                 "records": convert_and_respect_annotation_metadata(
                     object_=records, annotation=typing.Sequence[UpdateRecordData], direction="write"
                 ),
+                "updateType": update_type,
             },
             headers={
                 "content-type": "application/json",

flowvault/skyflow/generated/rest/records/types/__init__.py

@@ -0,0 +1,34 @@
+# This file was auto-generated by Fern from our API Definition.
+
+# isort: skip_file
+
+import typing
+from importlib import import_module
+
+if typing.TYPE_CHECKING:
+    from .update_request_update_type import UpdateRequestUpdateType
+_dynamic_imports: typing.Dict[str, str] = {"UpdateRequestUpdateType": ".update_request_update_type"}
+
+
+def __getattr__(attr_name: str) -> typing.Any:
+    module_name = _dynamic_imports.get(attr_name)
+    if module_name is None:
+        raise AttributeError(f"No {attr_name} found in _dynamic_imports for module name -> {__name__}")
+    try:
+        module = import_module(module_name, __package__)
+        if module_name == f".{attr_name}":
+            return module
+        else:
+            return getattr(module, attr_name)
+    except ImportError as e:
+        raise ImportError(f"Failed to import {attr_name} from {module_name}: {e}") from e
+    except AttributeError as e:
+        raise AttributeError(f"Failed to get {attr_name} from {module_name}: {e}") from e
+
+
+def __dir__():
+    lazy_attrs = list(_dynamic_imports.keys())
+    return sorted(lazy_attrs)
+
+
+__all__ = ["UpdateRequestUpdateType"]

flowvault/skyflow/generated/rest/records/types/update_request_update_type.py

@@ -0,0 +1,5 @@
+# This file was auto-generated by Fern from our API Definition.
+
+import typing
+
+UpdateRequestUpdateType = typing.Union[typing.Literal["UPDATE", "REPLACE"], typing.Any]

flowvault/skyflow/generated/rest/types/__init__.py

@@ -29,6 +29,7 @@
     from .tokenize_response_object import TokenizeResponseObject
     from .unique_value import UniqueValue
     from .update_record_data import UpdateRecordData
+    from .update_record_data_update_type import UpdateRecordDataUpdateType
     from .update_response import UpdateResponse
     from .upsert import Upsert
     from .upsert_update_type import UpsertUpdateType
@@ -56,6 +57,7 @@
     "TokenizeResponseObject": ".tokenize_response_object",
     "UniqueValue": ".unique_value",
     "UpdateRecordData": ".update_record_data",
+    "UpdateRecordDataUpdateType": ".update_record_data_update_type",
     "UpdateResponse": ".update_response",
     "Upsert": ".upsert",
     "UpsertUpdateType": ".upsert_update_type",
@@ -107,6 +109,7 @@ def __dir__():
     "TokenizeResponseObject",
     "UniqueValue",
     "UpdateRecordData",
+    "UpdateRecordDataUpdateType",
     "UpdateResponse",
     "Upsert",
     "UpsertUpdateType",

flowvault/skyflow/generated/rest/types/update_record_data.py

@@ -6,6 +6,7 @@
 import typing_extensions
 from ..core.pydantic_utilities import IS_PYDANTIC_V2, UniversalBaseModel
 from ..core.serialization import FieldMetadata
+from .update_record_data_update_type import UpdateRecordDataUpdateType
 
 
 class UpdateRecordData(UniversalBaseModel):
@@ -32,6 +33,15 @@ class UpdateRecordData(UniversalBaseModel):
     Name of the table to update data in.
     """
 
+    update_type: typing_extensions.Annotated[
+        typing.Optional[UpdateRecordDataUpdateType],
+        FieldMetadata(alias="updateType"),
+        pydantic.Field(alias="updateType", description="Type of update operation to perform."),
+    ] = None
+    """
+    Type of update operation to perform.
+    """
+
     if IS_PYDANTIC_V2:
         model_config: typing.ClassVar[pydantic.ConfigDict] = pydantic.ConfigDict(extra="allow", frozen=True)  # type: ignore # Pydantic v2
     else:

flowvault/skyflow/generated/rest/types/update_record_data_update_type.py

@@ -0,0 +1,5 @@
+# This file was auto-generated by Fern from our API Definition.
+
+import typing
+
+UpdateRecordDataUpdateType = typing.Union[typing.Literal["UPDATE", "REPLACE"], typing.Any]