diff --git a/dlt/destinations/impl/lancedb/lancedb_client.py b/dlt/destinations/impl/lancedb/lancedb_client.py index 601786e3ee..3feb8722c4 100644 --- a/dlt/destinations/impl/lancedb/lancedb_client.py +++ b/dlt/destinations/impl/lancedb/lancedb_client.py @@ -442,7 +442,7 @@ def get_stored_state(self, pipeline_name: str) -> Optional[StateInfo]: def get_stored_schema_by_hash(self, schema_hash: str) -> StorageSchemaInfo: try: - table_name = self.make_qualified_table_name(self.schema.version_table_name) + table_name = self.schema.version_table_name response = ( self.db_client[table_name] .search()