FazBrowse GitHub Viewer | Trending |
URL:
| Home
Tools: [Download Repo ZIP]   [Original HTTPS Page]

feat: Databricks Unity Catalog Materialization by falloficaruss · Pull Request #6565 · feast-dev/feast · GitHub

Repository navigation

Draft
Changes from 1 commit
Commits
Show all changes
24 commits
Select commit Hold shift + click to select a range
0800f13
feat: Implement Databricks Unity Catalog offline store integration
falloficaruss Jun 14, 2026
3a4edcd
Merge branch 'master' into feat/databricks-uc-provider
falloficaruss Jun 16, 2026
664107f
fix: Initialize Databricks session in DatabricksUCOfflineStore valida…
falloficaruss Jun 16, 2026
3b30044
fix: Fix MyPy errors by asserting SparkSession is not None
falloficaruss Jun 21, 2026
6059c9d
Merge branch 'master' into feat/databricks-uc-provider
falloficaruss Jun 21, 2026
faa0675
feat: Register FeatureViews as Unity Catalog feature tables on feast …
falloficaruss Jun 27, 2026
327228c
fix: Rename schema to uc_schema, add missing type mappings, add tests…
falloficaruss Jun 28, 2026
147a572
Merge branch 'master' into feat/databricks-uc-registration
falloficaruss Jun 28, 2026
3d0c8ca
Merge branch 'master' into feat/databricks-uc-registration
falloficaruss Jul 1, 2026
16870f3
feat: Refactor L2 to build on Iceberg REST Catalog instead of Databri…
falloficaruss Jul 1, 2026
4f41ccf
feat: Implement UC-backed materialization via compute engine hooks (L3)
falloficaruss Jun 28, 2026
c2a0d27
feat: Add click-to-zoom lightbox for blog post images (#6575)
franciscojavierarceo Jul 1, 2026
9446524
fix: configure FIPS-compliant gRPC cipher suites for offline server
aniketpalu Jul 1, 2026
5ce0cf7
feat: Add OnlineStore for Aerospike (#6532)
vkagamlyk Jul 2, 2026
267abdf
fix: add debug logging for FIPS mode detection fallback
aniketpalu Jul 2, 2026
4193c0d
fix: Unblock nightly UI build (#6570)
franciscojavierarceo Jul 3, 2026
386599e
feat: Implement Iceberg REST Catalog-backed materialization (L3)
falloficaruss Jul 3, 2026
d08c7c4
Merge branch 'master' into feat/databricks-uc-materialization
falloficaruss Jul 3, 2026
b7eb48f
Merge branch 'master' into feat/databricks-uc-registration
falloficaruss Jul 3, 2026
40a3de3
fix: Resolve 4 mypy errors in spark offline store, iceberg catalog, a…
falloficaruss Jul 4, 2026
ce723ff
Merge remote-tracking branch 'origin/feat/databricks-uc-registration'…
falloficaruss Jul 4, 2026
a52ea37
fix: Eliminate TOCTOU race condition in Iceberg table registration
falloficaruss Jul 4, 2026
c70408e
Merge remote-tracking branch 'origin/feat/databricks-uc-registration'…
falloficaruss Jul 4, 2026
23d8c15
fix: Resolve materialization issues
falloficaruss Jul 4, 2026
File filter

Filter by extension

Filter by extension .py  (1) All 1 file type selected
Viewed files
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Unified
Split
Hide whitespace
Diff view
Unified
Split
Hide whitespace
Prev Previous commit
Next Next commit
fix: Eliminate TOCTOU race condition in Iceberg table registration
Signed-off-by: Abhishek Shinde <norizzabhii@gmail.com>
  • Loading branch information
falloficaruss committed Jul 4, 2026
commit a52ea37feae72c9150534ae2e3ddb5cff7725a8f
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters. Learn more about bidirectional Unicode characters
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,6 @@
from feast.infra.offline_stores.iceberg.catalog_manager import (
create_feature_table,
load_catalog,
table_exists,
update_table_properties,
)

Expand Down Expand Up @@ -107,35 +106,40 @@ def _register_single_feature_view(
owner = fv.owner or ""
tags = _build_tags(fv, project)

if table_exists(catalog, namespace, table_name):
update_table_properties(
try:
create_feature_table(
catalog=catalog,
namespace=namespace,
table_name=table_name,
entity_columns=fv.entity_columns,
feature_columns=fv.features,
primary_keys=primary_keys,
timestamp_field=timestamp_field,
description=description,
owner=owner,
project=project,
tags=tags,
)
click.echo(
f" ✓ Updated catalog table: {catalog_name}.{namespace}.{table_name}"
f" ✓ Created catalog table: {catalog_name}.{namespace}.{table_name}"
)
else:
create_feature_table(
except Exception as e:
from pyiceberg.exceptions import TableAlreadyExistsError

if not isinstance(e, TableAlreadyExistsError):
raise

update_table_properties(
catalog=catalog,
namespace=namespace,
table_name=table_name,
entity_columns=fv.entity_columns,
feature_columns=fv.features,
primary_keys=primary_keys,
timestamp_field=timestamp_field,
description=description,
owner=owner,
project=project,
tags=tags,
)
click.echo(
f" ✓ Created catalog table: {catalog_name}.{namespace}.{table_name}"
f" ✓ Updated catalog table: {catalog_name}.{namespace}.{table_name}"
)


Expand Down

Back | FazBrowse Home | New Git URL