kQj&ddlmZddlmZddlmZddlZddlmZddl Z ddl m Z m Z m Z mZmZmZmZmZmZddlmZddlmZddlZe j2d k\rdd l mZndd lmZdd lmZmZmZm Z ddl!Z"d d l#m$Z$ddl%m&Z&m'Z'm(Z(d dl)m*Z*m+Z+d dl,m-Z-m.Z.d dl/m0Z0m1Z1d dl2m3Z4d dl2m5Z5m6Z6d dl7m8Z8m9Z9m:Z:d dl;mm?Z?e rd dl@mAZAmBZBd dlCmDZDddlEmFZFmGZGmHZHmIZId dlJmKZKd dlLmMZMd dlNmOZOd$dZP d%dZQd&dZRd'd ZSd(d!ZTGd"d#e*ZUy))) annotations)replace) timedeltaN)ThreadPoolExecutor) TYPE_CHECKINGAnyDictIterableListOptionalSequenceTupleUnion)urlparse)UUID) )override) ClientConfig RetryConfig TimeoutConfig TlsConfig)DATA)ListingNamespaceListing TableListing) DBConnectionLOOP)FunctionVersion UdfDefinition)AsyncJobJob)Query)QueryDescriptionQueryParameters)MaterializedViewMaterializedViewSource SelectArg) EnvVarSecret SecretInfo)ViewDescription)JobInfoSession)EmbeddingFunctionConfig)LanceNamespaceCreateNamespaceResponseDescribeNamespaceResponseDropNamespaceResponse) LanceModel)Table)validate_table_namec*||jSdSN) total_seconds)values V/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/lancedb/remote/db.py_duration_secondsr<>s$)$55   ?4?c|yt|jt|jt|jt|jdS)N)timeoutconnect_timeout read_timeoutpool_idle_timeout)r<r?r@rArBconfigs r;_timeout_config_to_dictrEBsL~$V^^4,V-C-CD)&*=*=>.v/G/GH  r=c|j|j|j|j|j|j dS)Nretriesconnect_retries read_retriesbackoff_factorbackoff_jitterstatusesrGrCs r;_retry_config_to_dictrNOs>>>!11++ // //OO  r=cf|y|j|j|j|jdS)N cert_filekey_file ssl_ca_certassert_hostnamerPrCs r;_tls_config_to_dictrUZs6 ~%%OO))!11  r=c |j td|jt|jt |j |j|j|jt|jd|jd S)NzCannot serialize a remote connection with a header_provider. Use static api_key/extra_headers or provide a worker-side connection factory instead.) user_agent retry_configtimeout_configblob_request_concurrency extra_headers id_delimiter tls_configheader_provideruser_id) r^ ValueErrorrWrNrXrErYrZr[r\rUr]r_rCs r;_client_config_to_dictraes ) *  ''-f.A.AB1&2G2GH$*$C$C--++)&*;*;<>>  r=ceZdZdZ dB dCdZedZdDdZee dDdZ edEdZ edFdZ e dDd Z e dG dHd Ze dI dJd Ze dI dKd Ze dLd Ze dG dMdZe dIdd dNdZe dddddd dOdZddddd dPdZe dQddddd dRdZe ddddddd dSdZe ddddddd dTdZe dUdZe ddd dVdZe dW dXdZe dW dYd Ze dWdZd!Ze dW d[d"Ze dWd\d#Ze d$Z e dI d]d%Z!e d^d&Z"e ddd' d_d(Z#e dd d`d)Z$e dddd* dad+Z%e dd dbd,Z&e dd dcd-Z'e dd ddd.Z(e dd ddd/Z)e dd ded0Z*e dddd* dfd1Z+e dd dXd2Z,e dd dgd3Z-e dd dhd4Z.e dd dXd5Z/e dd dYd6Z0e dddd* dfd7Z1e ddd did8Z2e djd9Z3e dkd:Z4e dkd;Z5e ddd< dld=Z6e dmd>Z7e dnd?Z8e dod@Z9e dpdAZ:y)qRemoteDBConnectionz*A connection to a remote LanceDB database.Nc t|tr tdi|}n | t}|tjdt d|7tjdt dt ||j_|7tjdt dt ||j_ t|} | jdk7rtd | jd ||_ ||_||_||_| |_| |_| j&|_||_d d lm} t1j2| ||||| || | |_y)z%Connect to a remote LanceDB database.NzNrequest_thread_pool is no longer used and will be removed in a future release.r stacklevelzconnection_timeout is deprecated and will be removed in a future release. Please use client_config.timeout_config.connect_timeout instead.)secondszread_timeout is deprecated and will be removed in a future release. Please use client_config.timeout_config.read_timeout instead.dbzInvalid scheme: z, only accepts db://r) connect_async)api_keyregion host_overridesql_host_override client_configstorage_optionsread_consistency_interval) isinstancedictrwarningswarnDeprecationWarningrrYr@rArschemer`db_urlrjrkrlrmronetlocdb_namernlancedbrirrun_conn)selfrxrjrkrlrequest_thread_poolrnconnection_timeoutrArorprmparsedris r;__init__zRemoteDBConnection.__init__|s\ mT *(9=9M  "(NM  * MM$"    ) MM#  RST T   *!2.}} * *XX +"3+ /*C    r=ct|tr tdi|n |xs t}|jxsij D cic]\} } | j dvr| | } } } || d<|j |} |j| _|| _ |xsd| _ d| _ || _ || _ d| _t|| | _|du| _|| _| Scc} } w)N)x-lancedb-databasezx-lancedb-database-prefixrz us-east-1)r[rq)rrrsrr[itemslower__new__urirxrzrjrkrlrmrorrn_catalog_oauthr}) clsinnernameendpointrjrn oauth_configrmrDkeyr:headersresults r; _from_catalogz RemoteDBConnection._from_catalogs-.  )= )1<>  &339r@@B Uyy{"UU J  )-$%S!   B# '#4 !%&vWE ,D 8  # s C&c"d|jdS)NzRemoteConnect(name=))rzr~s r;__repr__zRemoteDBConnection.__repr__s$T\\N!44r=c.|jjSr8)r}rrs r;rzRemoteDBConnection.uriszz~~r=ctd)z7Remote connections do not expose a local cache session.z.session is not supported by remote connectionsNotImplementedErrorrs r;sessionzRemoteDBConnection.sessions""RSSr=ctd)zCRemote connections do not expose a local read consistency interval.z@read_consistency_interval is not supported by remote connectionsrrs r;rpz,RemoteDBConnection.read_consistency_intervals" N  r=c  t|ddr tdtjd|j|j |j |j|jt|j|jdS)NrFz[Cannot serialize a catalog connection using OAuth; provide a worker-side connection factoryremote)connection_typerxrjrkrlrmrnro) getattrr`jsondumpsrxrjrkrlrmrarnrors r; serializezRemoteDBConnection.serializesz 4)5 1; zz#+++<<++!%!3!3%)%;%;!78J8J!K#'#7#7   r=cX|g}t|jj|||S)aList immediate child namespace names in the given namespace. Parameters ---------- namespace_path: List[str], optional The parent namespace to list namespaces in. None or empty list represents root namespace. page_token: str, optional Token for pagination. Use the token from a previous response to get the next page of results. limit: int, optional The maximum number of results to return. Returns ------- NamespaceListing Response containing namespace names and optional page_token for pagination. namespace_path page_tokenlimit)rr}list_namespacesr~rrrs r;rz"RemoteDBConnection.list_namespacess:2  !N JJ & &-*E '   r=cdtj|jj|||S)a2Create a new namespace. Parameters ---------- namespace_path: List[str] The namespace identifier to create. mode: str, optional Creation mode - "create" (fail if exists), "exist_ok" (skip if exists), or "overwrite" (replace if exists). Case insensitive. properties: Dict[str, str], optional Properties to set on the namespace. Returns ------- CreateNamespaceResponse Response containing the properties of the created namespace. )rmode properties)rr|r}create_namespace)r~rrrs r;rz#RemoteDBConnection.create_namespace8s30xx JJ ' '-DZ (   r=cdtj|jj|||S)a%Drop a namespace. Parameters ---------- namespace_path: List[str] The namespace identifier to drop. mode: str, optional Whether to skip if not exists ("SKIP") or fail ("FAIL"). Case insensitive. behavior: str, optional Whether to restrict drop if not empty ("RESTRICT") or cascade ("CASCADE"). Case insensitive. Returns ------- DropNamespaceResponse Response containing properties and transaction_id if applicable. )rrbehavior)rr|r}drop_namespace)r~rrrs r;rz!RemoteDBConnection.drop_namespaceVs30xx JJ % %-D8 &   r=c`tj|jj|S)aDescribe a namespace. Parameters ---------- namespace_path: List[str] The namespace identifier to describe. Returns ------- DescribeNamespaceResponse Response containing the namespace properties. r)rr|r}describe_namespacer~rs r;rz%RemoteDBConnection.describe_namespacets% xx 55^5TUUr=cX|g}t|jj|||S)aList a page of tables in this database. Parameters ---------- namespace_path: List[str], optional The namespace to list tables in. None or empty list represents root namespace. page_token: str, optional Token for pagination. Use the token from a previous response to get the next page of results. limit: int, optional The maximum number of results to return, default 100. Zero returns an empty page without a continuation token. Returns ------- TableListing Response containing table names and optional page_token for pagination. r)rr} list_tablesrs r;rzRemoteDBConnection.list_tabless:4  !N JJ " "-*E #   r=rcddl}|jdtd|g}tj|j j |||S)a{List the names of all tables in the database. .. deprecated:: Use :meth:`list_tables` instead, which provides proper pagination support. Parameters ---------- namespace_path: List[str], default [] The namespace to list tables in. Empty list represents root namespace. page_token: str The last token to start the new page. limit: int, optional The maximum number of tables to return. None returns all tables; zero returns an empty list. Returns ------- An iterator of table names. rNz6table_names() is deprecated, use list_tables() insteadrre)r start_afterr)rtrurvrr|r} table_names)r~rrrrts r;rzRemoteDBConnection.table_namessZ8  D   !Nxx JJ " "-:U #   r=)rroindex_cache_sizebranchversionc$ddlm}|g}tj|jj ||||}|||j |j|} || jj||} | S|| j|| S)aOpen a Lance Table in the database. Parameters ---------- name: str The name of the table. namespace_path: List[str], optional The namespace to open the table from. None or empty list represents root namespace. branch: str, optional If provided, open a handle scoped to this branch instead of the default branch. Reads and writes operate in the branch's context. version: int, optional If provided, open the table pinned to this version, producing a read-only handle. Composes with ``branch``: when both are given, opens that branch at the version; otherwise opens ``main`` at the version. Call ``checkout_latest`` to return to a writable state. Returns ------- A LanceTable object representing the table.  RemoteTable)rrorconnection_stater) tablerrr|r} open_tablerzrbranchescheckout) r~rrrorrrrrtbls r;rzRemoteDBConnection.open_tablesB '  !N JJ ! !- /!1 "    LL!^^)    ,,''8C  LL ! r=Ttarget_namespace_pathsource_version source_tag is_shallowc ddlm}|g}tj|jj ||||||}|||j |j|S)aIClone a table from a source table. Parameters ---------- target_table_name: str The name of the target table to create. source_uri: str The URI of the source table to clone from. target_namespace_path: List[str], optional The namespace for the target table. None or empty list represents root namespace. source_version: int, optional The version of the source table to clone. source_tag: str, optional The tag of the source table to clone. is_shallow: bool, default True Whether to perform a shallow clone (True) or deep clone (False). Currently only shallow clone is supported. Returns ------- A RemoteTable object representing the cloned table. rrrr)rrrr|r} clone_tablerzr) r~target_table_name source_urirrrrrrs r;rzRemoteDBConnection.clone_table snB ' ($& ! JJ " "!&;-%% #     LL!^^0   r=F)rrodata_storage_versionenable_v2_manifest_pathsc  6d| fd| ffD]\} }| t| d|r |dk(rd}n|sd}| g} t|ddlm}t j |j j||| ||||||  }|||j|j| S) aCreate a [Table][lancedb.table.Table] in the database. Parameters ---------- name: str The name of the table. namespace_path: List[str], optional The namespace to create the table in. None or empty list represents root namespace. data: The data to initialize the table, *optional* User must provide at least one of `data` or `schema`. Acceptable types are: - dict or list-of-dict - pandas.DataFrame - pyarrow.Table or pyarrow.RecordBatch schema: The schema of the table, *optional* Acceptable types are: - pyarrow.Schema - [LanceModel][lancedb.pydantic.LanceModel] mode: str, default "create" The mode to use when creating the table. Can be either "create", "overwrite", or "exist_ok". exist_ok: bool, default False If exist_ok is True, and mode is None or "create", mode will be changed to "exist_ok". on_bad_vectors: str, default "error" What to do if any of the vectors are not the same size or contains NaNs. One of "error", "drop", "fill". fill_value: float The value to use when filling vectors. Only used if on_bad_vectors="fill". embedding_functions: list of EmbeddingFunctionConfig, optional The embedding functions to store in the table schema and use to generate vectors when creating the table or adding data. storage_options: dict, optional Not supported for remote table creation. Raises NotImplementedError. data_storage_version: str, optional Not supported for remote table creation. Raises NotImplementedError. enable_v2_manifest_paths: bool, optional Not supported for remote table creation. Raises NotImplementedError. Returns ------- LanceTable A reference to the newly created table. !!! note The vector index won't be created by default. To create the index, call the `create_index` method on the table. Examples -------- Can create with list of tuples or dictionaries: >>> import lancedb >>> db = lancedb.connect("db://...", api_key="...", # doctest: +SKIP ... region="...") # doctest: +SKIP >>> data = [{"vector": [1.1, 1.2], "lat": 45.5, "long": -122.7}, ... {"vector": [0.2, 1.8], "lat": 40.1, "long": -74.1}] >>> db.create_table("my_table", data) # doctest: +SKIP LanceTable(my_table) You can also pass a pandas DataFrame: >>> import pandas as pd >>> data = pd.DataFrame({ ... "vector": [[1.1, 1.2], [0.2, 1.8]], ... "lat": [45.5, 40.1], ... "long": [-122.7, -74.1] ... }) >>> db.create_table("table2", data) # doctest: +SKIP LanceTable(table2) >>> custom_schema = pa.schema([ ... pa.field("vector", pa.list_(pa.float32(), 2)), ... pa.field("lat", pa.float32()), ... pa.field("long", pa.float32()) ... ]) >>> db.create_table("table3", data, schema = custom_schema) # doctest: +SKIP LanceTable(table3) It is also possible to create an table from `[Iterable[pa.RecordBatch]]`: >>> import pyarrow as pa >>> def make_batches(): ... for i in range(5): ... yield pa.RecordBatch.from_arrays( ... [ ... pa.array([[3.1, 4.1], [5.9, 26.5]], ... pa.list_(pa.float32(), 2)), ... pa.array(["foo", "bar"]), ... pa.array([10.0, 20.0]), ... ], ... ["vector", "item", "price"], ... ) >>> schema=pa.schema([ ... pa.field("vector", pa.list_(pa.float32(), 2)), ... pa.field("item", pa.utf8()), ... pa.field("price", pa.float32()), ... ]) >>> db.create_table("table4", make_batches(), schema=schema) # doctest: +SKIP LanceTable(table4) rrz+ is not supported for remote table creationcreateexist_okrr)rrschemaon_bad_vectors fill_valueembedding_functionsror) rr6rrrr|r} create_tablerzr)r~rdatarrrrrrrrorroptionr:rrs r;rzRemoteDBConnection.create_tableBs@$%9 : ')A B  MFE )hIJ   x!!  !ND!& JJ # #--%$7 / $     LL!^^)   r=selectwherer with_no_dataauto_refresh_enabledauto_refresh_interval_secondsc ddlm} tj|jj ||||||||} t | | j|j|jgS)Nrrrr) rrrr|r}create_materialized_viewr'rzr) r~rsourcerrrrrrrviews r;rz+RemoteDBConnection.create_materialized_viewss 'xx JJ / /)%9.K 0      !%!    r=c tj|jj||||||||} t | S)Nr)rr|r}create_materialized_view_asyncr#) r~rrrrrrrrjobs r;rz1RemoteDBConnection.create_materialized_view_async sLhh JJ 5 5)%9.K 6   3xr=cRt|j|}|j|Sr8)r'r definition)r~rrs r;open_materialized_viewz)RemoteDBConnection.open_materialized_view's! 56  r=r page_limitcNt|jj||S)aList materialized views. Returns a lazy iterator. ``page_limit`` limits each request, not the total; ``page_token`` resumes from a saved token. Requests and errors occur during iteration. See [pagination state][lancedb.listing.AsyncListing]. r)rr}list_materialized_viewsr~rrs r;rz*RemoteDBConnection.list_materialized_views-s- JJ . .%* /   r=cl|g}tj|jj||yNr)rr|r}drop_materialized_viewr~rrs r;rz)RemoteDBConnection.drop_materialized_view=s/  !N 2242WXr=c|g}tj|jj||}t |Sr)rr|r}drop_materialized_view_asyncr#r~rrrs r;rz/RemoteDBConnection.drop_materialized_view_asyncEs?  !Nhh JJ 3 3D 3 X 3xr=cl|g}tj|jj||y)aDrop a table from the database. Parameters ---------- name: str The name of the table. namespace_path: List[str], optional The namespace to drop the table from. None or empty list represents root namespace. Nr)rr|r} drop_tablers r;rzRemoteDBConnection.drop_tablePs/  !N &&tN&KLr=c|g}tj|jj||}t t |t r|St |S)z2Start dropping a table and return its cleanup job.r)rr|r}drop_table_asyncr#rrr"rs r;rz#RemoteDBConnection.drop_table_async`sQ  !Nhhtzz2242WX*S(33GG#GGr=cbtj|jj|y)zDrop all tables from the database. The remote API does not currently support this operation. Use ``list_tables()`` and ``drop_table()`` to drop tables individually. rN)rr|r}drop_all_tablesrs r;rz"RemoteDBConnection.drop_all_tablesjs" ++>+JKr=c^tj|jjy)z+Deprecated alias for ``drop_all_tables()``.N)rr|r} drop_databasers r;rz RemoteDBConnection.drop_databasess ))+,r=cx|g}|g}tj|jj||||y)zRename a table in the database. Parameters ---------- cur_name: str The current name of the table. new_name: str The new name of the table. N)cur_namespace_pathnew_namespace_path)rr|r} rename_table)r~cur_namenew_namerrs r;rzRemoteDBConnection.rename_tablexsK"  %!#   %!#   JJ # ##5#5 $  r=cpttj|jj |S)zmOpen a server-side job by id. See [DBConnection.open_job][lancedb.db.DBConnection.open_job]. )r#rr|r}open_jobr~job_ids r;r zRemoteDBConnection.open_jobs' 488DJJ//7899r=secretsrcztj|jj|||}t |S)Nr )rr|r}create_function_asyncr#)r~rrrrs r;rz(RemoteDBConnection.create_function_asyncs;hh JJ , ,GN -   3xr=cdtj|jj|||SN)rr)rr|r} get_functionr~rrrs r;rzRemoteDBConnection.get_functions3xx JJ # #gn $   r=rrrcPt|jj|||S)a List functions. Returns a lazy iterator. ``page_limit`` limits each request, not the total; ``page_token`` resumes from a saved token. Requests and errors occur during iteration. See [pagination state][lancedb.listing.AsyncListing]. r)rr}list_functionsr~rrrs r;rz!RemoteDBConnection.list_functionss1 JJ % %-%% &   r=cdtj|jj|||Sr)rr|r} drop_functionrs r;rz RemoteDBConnection.drop_functions3xx JJ $ $gn %   r=ctj|jj|||\}}|t |fSr)rr|r}drop_function_asyncr#)r~rrrdroppedrs r;rz&RemoteDBConnection.drop_function_asyncsExx JJ * *gn +   C  r=cftj|jj|||yr)rr|r} create_secretr~rr:rs r;rz RemoteDBConnection.create_secrets& ))$n)UVr=cftj|jj|||yr)rr|r} alter_secretr s r;r"zRemoteDBConnection.alter_secrets& ((u^(TUr=cbtj|jj||Sr)rr|r}describe_secretrs r;r$z"RemoteDBConnection.describe_secrets'xx 2242WXXr=cPt|jj|||S)aList secrets. Returns a lazy iterator. ``page_limit`` limits each request, not the total; ``page_token`` resumes from a saved token. Requests and errors occur during iteration. See [pagination state][lancedb.listing.AsyncListing]. r)rr} list_secretsrs r;r&zRemoteDBConnection.list_secretss1 JJ # #-%% $   r=cdtj|jj||yr)rr|r} drop_secretrs r;r(zRemoteDBConnection.drop_secrets$ ''^'LMr=cdtj|jj|||Sr)rr|r} create_view)r~rqueryrs r;r*zRemoteDBConnection.create_views.xx JJ " "4~ " N  r=cbtj|jj||Sr)rr|r} describe_viewrs r;r-z RemoteDBConnection.describe_view#s'xx 00n0UVVr=cdtj|jj||yr)rr|r} drop_viewrs r;r/zRemoteDBConnection.drop_view)s$ %%d>%JKr=cxtj|jj||}t |Sr)rr|r}drop_view_asyncr#rs r;r1z"RemoteDBConnection.drop_view_async/s/hhtzz11$~1VW3xr=cPt|jj|||S)aList views. Returns a lazy iterator. ``page_limit`` limits each request, not the total; ``page_token`` resumes from a saved token. Requests and errors occur during iteration. See [pagination state][lancedb.listing.AsyncListing]. r)rr} list_viewsrs r;r3zRemoteDBConnection.list_views6s1 JJ ! !-%% "   r=cNt|jj||S)a.List server-side jobs across the database's tables. Returns a lazy iterator. ``page_limit`` limits each request, not the total; ``page_token`` resumes from a saved token. Requests and errors occur during iteration. See [pagination state][lancedb.listing.AsyncListing]. r)rr} list_jobsrs r;r5zRemoteDBConnection.list_jobsLs( JJ J: N  r=c^tj|jj|S)zRequest cancellation of a server-side job by id. Returns True if the server accepted the cancellation, False if no such job exists. Cancelling an already-terminal job is a no-op success. )rr|r} cancel_jobr s r;r7zRemoteDBConnection.cancel_jobZs"xx --f566r=c^tj|jj|S)zfPause a server-side job by id. Returns "pausing", "already_paused", or "committing". )rr|r} pause_jobr s r;r9zRemoteDBConnection.pause_jobds" xx ,,V455r=c^tj|jj|S)zmResume a paused server-side job by id. Returns "resumed", "still_pausing", or "not_paused". )rr|r} resume_jobr s r;r;zRemoteDBConnection.resume_jobls" xx --f566r=default_namespace_path parametersc vttj|jj |||S)aStart executing SQL through this remote connection. Unqualified tables use this connection's database and the ``["public"]`` namespace by default. Fully qualified table names may reference other databases available to the same deployment. ``parameters`` binds values to ``$1`` / ``$name`` placeholders; see [DBConnection.execute_query_async][lancedb.db.DBConnection.execute_query_async]. r<)SqlQueryrr|r}execute_query_async)r~r+r=r>s r;rAz&RemoteDBConnection.execute_query_asyncts=  HH ..+A)/   r=c^tj|jj|S)z;Describe a submitted SQL query by its connection-scoped id.)rr|r}describe_query)r~query_ids r;rCz!RemoteDBConnection.describe_querys*xx JJ % %   r=c\tj|jjS)zGet the equivalent namespace client for this connection. Returns a RestNamespace with the same URI and authentication headers. Returns ------- LanceNamespace The namespace client for this connection. )rr|r}namespace_clientrs r;rFz#RemoteDBConnection.namespace_clients xx 33566r=c6|jjSr8)r}is_openrs r;rHzRemoteDBConnection.is_openszz!!##r=c8|jjyr8)r}closers r;rJzRemoteDBConnection.closes r=)NNNNNNNN)rxstrrjrKrkrKrl Optional[str]rzOptional[ThreadPoolExecutor]rnz)Union[ClientConfig, Dict[str, Any], None]rOptional[float]rArMroOptional[Dict[str, str]]rpOptional[timedelta]rmrL)returnrK)rPzOptional['Session'])rPrO)NNN)rOptional[List[str]]rrLr Optional[int]rPr)NN)r List[str]rrLrrNrPr1)rrSrrLrrLrPr3)rrSrPr2)rrQrrLrrRrPr)rrLrrRrrQrPz Iterable[str])rrKrrQrorNrrRrrLrrRrPr5)rrKrrKrrQrrRrrLrboolrPr5)NNNFerrorgN)rrKrrrz&Optional[Union[pa.Schema, LanceModel]]rrLrrTrrKrfloatrz'Optional[List[EmbeddingFunctionConfig]]rrQrorNrrLrOptional[bool]rPr5)rrKrr(rr)rrLrrRrrTrrWrrMrPr')rrKrr(rr)rrLrrRrrTrrWrrMrP Job[None])rrKrPr')rrLrrRrP Listing[str]r8)rrKrrQrPNone)rrKrrQrPrX)rrKrrQ)rrKrrQrPr#)rrQ)rrKrrKrrQrrQ)r rKrPr#)rr!rz Optional[Sequence[EnvVarSecret]]rrQrPzJob[FunctionVersion])rrKrrKrrQrPr )rrQrrLrrRrPzListing[FunctionVersion])rrKrrKrrQrPrT)rrKrrKrrQrPzTuple[bool, Job])rrKr:rKrrQrPrZ)rrKrrQrPr+)rrQrrLrrRrPrY)rrKr+rKrrQrPr,)rrKrrQrPr,)rrLrrRrPzListing[JobInfo])r rKrPrT)r rKrPrK)r+rKr=rQr>zOptional[QueryParameters]rPr@)rDzUnion[UUID, str]rPr%)rPr0)rPrT)rPrZ);__name__ __module__ __qualname____doc__r classmethodrrpropertyrrrrprrrrrrrrrrrrrrrrrrrrrr rrrrrrr"r$r&r(r*r-r/r1r3r5r7r9r;rArCrFrHrJrqr=r;rcrcys 4(,<@CG.2(,489=+/N N N  N % N : N AN ,N &N 2N $7N )N `  D5 TT    &/3$(#  + "      @#/3  !  -  !   :#"&  !       :V'V "VV"/3$(#  + "      B%)#( /3 ( !( ( , (  ( ( T /348*. $!%66, 6 2 6 ( 666 66z6:(,$(4 4 4 3 4 & 4 "4 4  4 l9="%GKc /348.237c c c 7 c  c  c c c Ec ,c 2c ,c #1c  c c J !##"/39=! ! '!  !  ! ! ! -! (7!  ! ! F !##"/39='    -(7 4 -1t  *  ?L      ?CYY)<Y YY?C)<  M M?CHH)<H HHLL-- 3726    0  0   :::  59.2 ! 2  ,     /3      ,      /3$($(  , "  "  "   * /3      ,       /3 ! ! ! , !  ! !NRWW #W8KW WW NRVV #V8KV VV BFYY,?Y YY /3$($(  , "  "     *BFNN,?N NN NR  # 8K   BFWW,?W WW BFLL,?L LL BF,?  /3$($(  , "  "     *-1t  *  ?L      776677 7;04   !4  .     2   7 7$$r=rc)r:rOrPrM)rDzOptional[TimeoutConfig]rPOptional[dict[str, Any]])rDrrPdict[str, Any])rDzOptional[TlsConfig]rPra)rDrrPrb)V __future__r dataclassesrdatetimerrconcurrent.futuresrsystypingrrr r r r r rr urllib.parseruuidrrt version_infor overrideslancedb.remoterrrrpyarrowpacommonrlancedb.listingrrrrhrr functionsr r!rr"r#sqlr$r@r%r&materialized_viewr'r(r)rr*r+rr,_lancedbr-r. embeddingsr/lance_namespacer0r1r2r3pydanticr4rr5utilr6r<rErNrUrarcrqr=r;rzs # 1    "w"ONCC#6#3SS."+0 "&@  #  (qqr=