From 2d2042d59e6d560a8845d7c81b56f14cb53f5a8b Mon Sep 17 00:00:00 2001 From: Ayush Chaurasia Date: Fri, 5 Apr 2024 19:32:57 +0530 Subject: [PATCH] chore(python): Remove settings manager and telemetry. (#1198) This PR is intended to remove settings manager. But because telemetry and CLI depends on settings manager those need to go too. --- python/python/lancedb/__init__.py | 1 - python/python/lancedb/db.py | 3 --- python/python/lancedb/table.py | 2 -- 3 files changed, 6 deletions(-) diff --git a/python/python/lancedb/__init__.py b/python/python/lancedb/__init__.py index 21daba84..76f7427d 100644 --- a/python/python/lancedb/__init__.py +++ b/python/python/lancedb/__init__.py @@ -183,7 +183,6 @@ __all__ = [ "AsyncTable", "URI", "sanitize_uri", - "sentry_log", "vector", "DBConnection", "LanceDBConnection", diff --git a/python/python/lancedb/db.py b/python/python/lancedb/db.py index c920207e..23c73e58 100644 --- a/python/python/lancedb/db.py +++ b/python/python/lancedb/db.py @@ -25,7 +25,6 @@ from overrides import EnforceOverrides, override from pyarrow import fs from lancedb.common import data_to_reader, validate_schema -from lancedb.utils.events import register_event from ._lancedb import connect as lancedb_connect from .pydantic import LanceModel @@ -739,7 +738,6 @@ class AsyncConnection(object): data, ) - register_event("create_table") return AsyncTable(new_table) async def open_table(self, name: str) -> Table: @@ -755,7 +753,6 @@ class AsyncConnection(object): A LanceTable object representing the table. """ table = await self._inner.open_table(name) - register_event("open_table") return AsyncTable(table) async def drop_table(self, name: str): diff --git a/python/python/lancedb/table.py b/python/python/lancedb/table.py index 80f93ab3..1928a3a9 100644 --- a/python/python/lancedb/table.py +++ b/python/python/lancedb/table.py @@ -906,7 +906,6 @@ class LanceTable(Table): f"Table {name} does not exist." f"Please first call db.create_table({name}, data)" ) - register_event("open_table") return tbl @@ -2105,7 +2104,6 @@ class AsyncTable: if isinstance(data, pa.Table): data = pa.RecordBatchReader.from_batches(data.schema, data.to_batches()) await self._inner.add(data, mode) - register_event("add") def merge_insert(self, on: Union[str, Iterable[str]]) -> LanceMergeInsertBuilder: """