diff --git a/sdk/python/feast/type_map.py b/sdk/python/feast/type_map.py index 60d22a48ea9..da3093f2a19 100644 --- a/sdk/python/feast/type_map.py +++ b/sdk/python/feast/type_map.py @@ -1092,7 +1092,7 @@ def pa_to_feast_value_type(pa_type_as_str: str) -> ValueType: elif pa_type_as_str.startswith("map<"): value_type = ValueType.MAP elif pa_type_as_str == "large_string": - value_type = ValueType.STRING + value_type = ValueType.JSON elif pa_type_as_str.startswith("struct<") or pa_type_as_str.startswith("struct{"): value_type = ValueType.STRUCT else: diff --git a/sdk/python/tests/integration/dbt/conftest.py b/sdk/python/tests/integration/dbt/conftest.py index d1df145f3ec..00ee01e7027 100644 --- a/sdk/python/tests/integration/dbt/conftest.py +++ b/sdk/python/tests/integration/dbt/conftest.py @@ -29,4 +29,7 @@ def pytest_collection_modifyitems(config, items): # noqa: ARG001 reason="dbt manifest.json not found - run 'dbt build' first or use dbt-integration-test workflow" ) for item in items: - item.add_marker(skip_marker) + if str(TEST_DBT_PROJECT_DIR) in str(item.fspath) or "/dbt/" in str( + item.fspath + ): + item.add_marker(skip_marker) diff --git a/sdk/python/tests/unit/local_feast_tests/test_feature_service.py b/sdk/python/tests/unit/local_feast_tests/test_feature_service.py index 75ceb463085..13a1dddf542 100644 --- a/sdk/python/tests/unit/local_feast_tests/test_feature_service.py +++ b/sdk/python/tests/unit/local_feast_tests/test_feature_service.py @@ -71,7 +71,7 @@ def test_apply_with_fv_inference() -> None: fs = store.get_feature_service("all_stats") assert len(fs.feature_view_projections) == 2 - assert len(fs.feature_view_projections[0].features) == 3 + assert len(fs.feature_view_projections[0].features) == 6 assert len(fs.feature_view_projections[0].desired_features) == 0 assert len(fs.feature_view_projections[1].features) == 2 assert len(fs.feature_view_projections[1].desired_features) == 0