kQj!ddlmZmZddlmZddlmZmZddlm Z ddl m Z ddl m Z mZmZmZmZgdZeGd d ZeGd d ZeGd dZeGddZy)) dataclassfield) timedelta)ListOptional) __version__)HeaderProvider)ClientAuthMethod OAuthConfig OAuthFlowType OAuthSessionTokenCacheOptions) TimeoutConfig RetryConfig TlsConfig ClientConfigr r r r rrceZdZUdZdZeeed<dZeeed<dZ eeed<dZ eeed<e deefdZ d Z y) raTimeout configuration for remote HTTP client. Attributes ---------- timeout: Optional[timedelta] The overall timeout for the entire request. This includes connection, send, and read time. If the entire request doesn't complete within this time, it will fail. Default is None (no overall timeout). This can also be set via the environment variable `LANCE_CLIENT_TIMEOUT`, as an integer number of seconds. connect_timeout: Optional[timedelta] The timeout for establishing a connection. Default is 120 seconds (2 minutes). This can also be set via the environment variable `LANCE_CLIENT_CONNECT_TIMEOUT`, as an integer number of seconds. read_timeout: Optional[timedelta] The timeout for reading data from the server. Default is 300 seconds (5 minutes). This also applies while waiting for response headers during an upload. Increase it for large or slowly produced inputs to `create_table`, even if data is still being uploaded. This can also be set via the environment variable `LANCE_CLIENT_READ_TIMEOUT`, as an integer number of seconds. pool_idle_timeout: Optional[timedelta] The timeout for keeping idle connections in the connection pool. Default is 300 seconds (5 minutes). This can also be set via the environment variable `LANCE_CLIENT_CONNECTION_TIMEOUT`, as an integer number of seconds. Ntimeoutconnect_timeout read_timeoutpool_idle_timeoutreturnc|yt|tr|St|ttfr t|St d|d)N)secondszInvalid value for timeout: z*, must be a timedelta or number of seconds) isinstancerintfloat ValueError)values \/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/lancedb/remote/__init__.py__to_timedeltazTimeoutConfig.__to_timedeltaGsP = y )L U| ,U+ +-eW5'' c|j|j|_|j|j|_|j|j|_|j|j|_y)N)_TimeoutConfig__to_timedeltarrrrselfs r! __post_init__zTimeoutConfig.__post_init__Usc**4<<8 #2243G3GH //0A0AB!%!4!4T5K5K!Lr#)__name__ __module__ __qualname____doc__rrr__annotations__rrr staticmethodr%r(r#r!rr%sj6$(GXi '+/OXi(/(,L(9%,-1x *1 )!4  Mr#rceZdZUdZdZeeed<dZeeed<dZ eeed<dZ ee ed<dZ ee ed<dZ eeeed<y) ranRetry configuration for the remote HTTP client. Attributes ---------- retries: Optional[int] The maximum number of retries for a request. Default is 3. You can also set this via the environment variable `LANCE_CLIENT_MAX_RETRIES`. connect_retries: Optional[int] The maximum number of retries for connection errors. Default is 3. You can also set this via the environment variable `LANCE_CLIENT_CONNECT_RETRIES`. read_retries: Optional[int] The maximum number of retries for read errors. Default is 3. You can also set this via the environment variable `LANCE_CLIENT_READ_RETRIES`. backoff_factor: Optional[float] The backoff factor to apply between retries. Default is 0.25. Between each retry the client will wait for the amount of seconds: `{backoff factor} * (2 ** ({number of previous retries}))`. So for the default of 0.25, the first retry will wait 0.25 seconds, the second retry will wait 0.5 seconds, the third retry will wait 1 second, etc. You can also set this via the environment variable `LANCE_CLIENT_RETRY_BACKOFF_FACTOR`. backoff_jitter: Optional[float] The jitter to apply to the backoff factor, in seconds. Default is 0.25. A random value between 0 and `backoff_jitter` will be added to the backoff factor in seconds. So for the default of 0.25 seconds, between 0 and 250 milliseconds will be added to the sleep between each retry. You can also set this via the environment variable `LANCE_CLIENT_RETRY_BACKOFF_JITTER`. statuses: Optional[List[int] The HTTP status codes for which to retry the request. Default is [429, 500, 502, 503]. You can also set this via the environment variable `LANCE_CLIENT_RETRY_STATUSES`. Use a comma-separated list of integers. Nretriesconnect_retries read_retriesbackoff_factorbackoff_jitterstatuses)r)r*r+r,r1rrr-r2r3r4rr5r6rr/r#r!rr\sc%N"GXc]!%)OXc])"&L(3-&&*NHUO*&*NHUO*$(HhtCy!(r#rc\eZdZUdZdZeeed<dZeeed<dZ eeed<dZ e ed<y)raYTLS/mTLS configuration for the remote HTTP client. Attributes ---------- cert_file: Optional[str] Path to the client certificate file (PEM format) for mTLS authentication. key_file: Optional[str] Path to the client private key file (PEM format) for mTLS authentication. ssl_ca_cert: Optional[str] Path to the CA certificate file (PEM format) for server verification. assert_hostname: bool Whether to verify the hostname in the server's certificate. Default is True. Set to False to disable hostname verification (use with caution). N cert_filekey_file ssl_ca_certTassert_hostname) r)r*r+r,r8rstrr-r9r:r;boolr/r#r!rrs=  $Ix}#"Hhsm"!%K#% OT r#rceZdZUdZdeZeed<ee Z e ed<ee Z e e ed<dZe eed<dZe eed <dZe eed <dZe eed <dZe d ed <dZe eed<dZy)raConfiguration for the LanceDB Cloud HTTP client. Attributes ---------- user_agent: str User agent string sent with requests. retry_config: RetryConfig Configuration for retrying failed requests. timeout_config: Optional[TimeoutConfig] Configuration for request timeouts. blob_request_concurrency: Optional[int] Maximum concurrent blob HTTP requests across all handles on this connection. Defaults to 8. Set a positive integer here or via `LANCE_CLIENT_BLOB_REQUEST_CONCURRENCY`. extra_headers: Optional[dict] Additional headers to include in requests. id_delimiter: Optional[str] The delimiter joining a namespace path and a name into one object identifier. ``"$"`` is the only supported value, and leaving this unset is how to get it; anything else is rejected when the connection is created. tls_config: Optional[TlsConfig] TLS/mTLS configuration for secure connections. header_provider: Optional[HeaderProvider] Provider for dynamic headers to be added to each request. user_id: Optional[str] User identifier for tracking purposes. This is sent as the `x-lancedb-user-id` header in requests to LanceDB Cloud/Enterprise. This can also be set via the `LANCEDB_USER_ID` environment variable. Alternatively, set `LANCEDB_USER_ID_ENV_KEY` to specify another environment variable that contains the user ID value. zLanceDB-Python-Client/ user_agent)default_factory retry_configtimeout_configNblob_request_concurrency extra_headers id_delimiter tls_configr header_provideruser_idc>t|jtrtdi|j|_t|jtrt di|j|_t|j trtdi|j |_yy)Nr/)rrAdictrrBrrFrr&s r!r(zClientConfig.__post_init__st d'' . + @d.?.? @D  d))4 0"/"F$2E2E"FD  doot ,':$//:DO -r#)r)r*r+r,rr?r<r-rrrArrBrrCrrDrJrErFrrGrHr(r/r#r!rrs D/{m("&L(3-&&*J#*26OX./6!GXc]!;r#rN) dataclassesrrdatetimertypingrrlancedbrheaderr oauthr r r rr__all__rrrrr/r#r!rRs )!"  3M3M 3Ml -)-) -)` !! !, 3;3; 3;r#