Skip to content

Commit

Permalink
remove unused method from db stash
Browse files Browse the repository at this point in the history
  • Loading branch information
shubham3121 committed Sep 30, 2024
1 parent 9e98cf4 commit bc23abc
Showing 1 changed file with 0 additions and 48 deletions.
48 changes: 0 additions & 48 deletions packages/syft/src/syft/store/db/stash.py
Original file line number Diff line number Diff line change
Expand Up @@ -180,54 +180,6 @@ def _print_query(self, stmt: sa.sql.select) -> None:
def unique_fields(self) -> list[str]:
return getattr(self.object_type, "__attr_unique__", [])

@as_result(SyftException, StashException, NotFoundException)
@with_session
def get_by_unique_fields(
self,
credentials: SyftVerifyKey,
obj: StashT,
session: Session = None,
has_permission: bool = False,
) -> StashT:
query = self.query()

if not has_permission:
role = self.get_role(credentials, session=session)
query = query.with_permissions(credentials, role)

unique_fields = self.unique_fields

filters = []
for field_name in unique_fields:
field_value = getattr(obj, field_name, None)
if not is_json_primitive(field_value):
raise StashException(
f"Cannot check uniqueness of non-primitive field {field_name}"
)
if field_value is None:
continue
filters.append((field_name, "eq", field_value))

query = self.query()
query = query.filter_or(
*filters,
)

results = query.execute(session).all()

if len(results) == 1:
result = results[0]
elif len(results) > 1:
raise StashException(
f"Multiple objects found for unique fields: {unique_fields}"
)
else:
raise NotFoundException(
f"No object found for unique fields: {unique_fields}"
)

return result

@with_session
def is_unique(self, obj: StashT, session: Session = None) -> bool:
unique_fields = self.unique_fields
Expand Down

0 comments on commit bc23abc

Please sign in to comment.