diff --git a/‎sdk/python/feast/infra/data_sources/contrib/lance/lance_source.py‎
Lines changed: 3 additions & 5 deletions b/‎sdk/python/feast/infra/data_sources/contrib/lance/lance_source.py‎
Lines changed: 3 additions & 5 deletions
diff --git a/‎sdk/python/tests/unit/infra/data_sources/test_lance_source.py‎
Lines changed: 20 additions & 0 deletions b/‎sdk/python/tests/unit/infra/data_sources/test_lance_source.py‎
Lines changed: 20 additions & 0 deletions
@@ -31,7 +31,6 @@
 import json
 from typing import TYPE_CHECKING, Any, Callable, Dict, Iterable, List, Optional, Tuple
 
-from feast.credentials import ConnectionRef
 from feast.data_source import DataSource
 from feast.protos.feast.core.DataSource_pb2 import DataSource as DataSourceProto
 from feast.repo_config import RepoConfig
@@ -126,7 +125,6 @@ def __init__(
         description: Optional[str] = "",
         tags: Optional[Dict[str, str]] = None,
         owner: Optional[str] = "",
-        connection_ref: Optional[ConnectionRef] = None,
     ):
         if table_format is not None and not isinstance(table_format, LanceFormat):
             raise ValueError(
@@ -162,7 +160,6 @@ def __init__(
             description=description,
             tags=tags,
             owner=owner,
-            connection_ref=connection_ref,
         )
         self.uri = uri
         self.lance_table = table
@@ -282,9 +279,11 @@ def to_arrow(
                 of the result.
         """
         dataset = self.get_dataset()
+        if feature_view is not None:
+            _validate_against_feature_view(self, dataset.schema, feature_view)
+
         table = dataset.to_table(columns=columns)
         if feature_view is not None:
-            _validate_against_feature_view(self, table.schema, feature_view)
             from feast.utils import _validate_vector_field_lengths
 
             _validate_vector_field_lengths(table, feature_view)
@@ -395,7 +394,6 @@ def from_proto(data_source: DataSourceProto) -> Any:
             description=data_source.description,
             tags=tags,
             owner=data_source.owner,
-            connection_ref=ConnectionRef.from_tags(tags),
         )
 
 
 
@@ -25,6 +25,7 @@
 import pyarrow as pa
 import pytest
 
+from feast.credentials import ConnectionRef
 from feast.entity import Entity
 from feast.feature_view import FeatureView
 from feast.field import Field
@@ -135,6 +136,14 @@ def test_rejects_a_non_lance_table_format():
         LanceSource(uri="/tmp/x.lance", table_format=IcebergFormat())
 
 
+def test_rejects_an_unimplemented_connection_ref():
+    with pytest.raises(TypeError, match="unexpected keyword argument 'connection_ref'"):
+        LanceSource(
+            uri="s3://bucket/emb.lance",
+            connection_ref=ConnectionRef(provider="env", name="LANCE"),
+        )
+
+
 def test_default_name_is_the_uri_for_a_path_based_source():
     assert LanceSource(uri="/tmp/x.lance").name == "/tmp/x.lance"
 
@@ -259,6 +268,17 @@ def test_path_based_read_projects_columns(tmp_path):
     assert source.to_arrow(columns=["driver_id"]).column_names == ["driver_id"]
 
 
+def test_projection_validates_the_full_source_schema(tmp_path):
+    uri = str(tmp_path / "emb.lance")
+    _write(uri, _driver_stats())
+    source = LanceSource(uri=uri, timestamp_field="event_timestamp")
+    feature_view = _feature_view(source)
+
+    table = source.to_arrow(columns=["driver_id"], feature_view=feature_view)
+
+    assert table.column_names == ["driver_id"]
+
+
 def test_path_based_schema_inference(tmp_path):
     uri = str(tmp_path / "emb.lance")
     _write(uri, _driver_stats())