Skip to content
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
18 commits
Select commit Hold shift + click to select a range
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Minor formatting & type lints related changes
Signed-off-by: Aniket Paluskar <apaluska@redhat.com>
  • Loading branch information
aniketpalu committed Aug 7, 2025
commit 07657202a70f3a925303ffb5adb47176611ec33c
22 changes: 10 additions & 12 deletions sdk/python/feast/api/registry/rest/lineage.py
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
"""REST API endpoints for registry lineage and relationships."""

from typing import Optional
import logging
from typing import Optional

from fastapi import APIRouter, Depends, HTTPException, Query

Expand Down Expand Up @@ -156,7 +156,9 @@ def get_complete_registry_data(
sorting_params=sorting_params,
)
if errors and not project_resources:
logger.error(f"Error getting project resources for project {project}: {errors}")
logger.error(
f"Error getting project resources for project {project}: {errors}"
)
return {
"project": project,
"objects": {},
Expand All @@ -178,15 +180,9 @@ def get_complete_registry_data(
"pagination": {
# Get pagination metadata from project_resources if available, otherwise use empty dicts
"entities": pagination.get("entities", {}),
"dataSources": pagination.get(
"dataSources", {}
),
"featureViews": pagination.get(
"featureViews", {}
),
"featureServices": pagination.get(
"featureServices", {}
),
"dataSources": pagination.get("dataSources", {}),
"featureViews": pagination.get("featureViews", {}),
"featureServices": pagination.get("featureServices", {}),
"features": pagination.get("features", {}),
"relationships": lineage_response.get("relationshipsPagination", {}),
"indirectRelationships": lineage_response.get(
Expand Down Expand Up @@ -256,7 +252,9 @@ def get_complete_registry_data_all(
)

if errors and not project_resources:
logger.error(f"Error getting project resources for project {project_name}: {errors}")
logger.error(
f"Error getting project resources for project {project_name}: {errors}"
)
continue

# Add project field to each object
Expand Down
4 changes: 1 addition & 3 deletions sdk/python/feast/api/registry/rest/projects.py
Original file line number Diff line number Diff line change
@@ -1,8 +1,6 @@
from fastapi import APIRouter, Depends, Query

from feast.api.registry.rest.rest_utils import (
create_grpc_pagination_params,
create_grpc_sorting_params,
get_pagination_params,
get_sorting_params,
grpc_call,
Expand Down Expand Up @@ -42,7 +40,7 @@ def list_projects(
)
except Exception as e:
return {"error": str(e)}

if err_msg:
return {"error": err_msg}

Expand Down
Loading
Loading