SK-2954: Remove explanatory comments from a few files

Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com>

Author: saileshwar-skyflow

common/client/base_skyflow.py

@@ -167,9 +167,6 @@ def detect(self, vault_id=None):
         return vault_config.get(OptionField.DETECT_CONTROLLER)
 
     class Builder(ABC):
-        # -- hooks, filled in per-variant by make_skyflow_class() -- left None here so using
-        # this template directly (rather than through make_skyflow_class()) fails fast, with a
-        # clear message (see _REQUIRED_HOOKS check in __init__ below).
         _vault_client_cls = None
         _vault_controller_cls = None
         _connection_cls = None
@@ -186,8 +183,6 @@ class Builder(ABC):
         _validate_credentials = None
         _set_active_log_level = None
 
-        # Connection/Detect support and their validators are legitimately optional per variant --
-        # everything else must be supplied by make_skyflow_class() before this Builder is usable.
         _REQUIRED_HOOKS = (
             '_vault_client_cls', '_vault_controller_cls', '_logger_cls', '_default_log_level',
             '_skyflow_messages', '_skyflow_cls', '_validate_vault_config',

common/vault/base_vault_client.py

@@ -52,8 +52,6 @@ def initialize_client_configuration(self):
                                                        logger=self._logger)
             self._is_static_token = CredentialField.TOKEN in self._credentials or CredentialField.API_KEY in self._credentials
         bearer_token = self.get_bearer_token(self._credentials)
-        # Cache unconditionally (not just on the generated-token branch) so
-        # get_current_bearer_token() reflects static tokens/API keys too.
         self._bearer_token = bearer_token
         if needs_reinit:
             self.initialize_api_client(self._vault_url, bearer_token)

flowvault/skyflow_flowvault/vault/client/client.py

@@ -8,8 +8,6 @@ def resolve_vault_url(self, cluster_id, env, vault_id, logger=None):
         return get_vault_url(cluster_id, env, vault_id, logger=logger)
 
     def initialize_api_client(self, vault_url, bearer_token):
-        # SkyflowAuth has no `token` param -- auth is injected per-call instead (see
-        # VaultController.__build_headers).
         self._api_client = SkyflowAuth(base_url=vault_url)
 
     def get_insert_api(self):

flowvault/skyflow_flowvault/vault/controller/_vault.py

@@ -46,7 +46,6 @@ def insert(self, request: InsertRequest) -> InsertResponse:
                 table_name=None if needs_per_record_table else request.table,
                 upsert=None if needs_per_record_upsert else self.__to_v1_upsert(request.upsert),
             )
-            # with_raw_response so x-request-id is available to tag onto each result.
             raw_response = insert_api.with_raw_response.insert(
                 vault_id=self._vault_client.get_vault_id(),
                 records=wire_records,
@@ -84,8 +83,6 @@ def __build_wire_record(self, record, request, needs_per_record_table, needs_per
         ))
 
     def __omit_none(self, **kwargs):
-        # A field explicitly passed as None still serializes as null; omitting the kwarg
-        # entirely is what actually excludes it from the outgoing JSON.
         return {k: v for k, v in kwargs.items() if v is not None}
 
     def __build_headers(self):
@@ -136,7 +133,6 @@ def __flatten_tokens(self, tokens):
         return flat
 
     def __errors_from_exception(self, e, records, start_index):
-        # Prefers a structured per-record error body over one flat message per batch.
         if isinstance(e, ApiError):
             request_id = self.__extract_request_id(e.headers)
             body = e.body if isinstance(e.body, dict) else None