Skip to content

Commit

Permalink
🎨 call scan on profile.opened.store
Browse files Browse the repository at this point in the history
Signed-off-by: ff137 <ff137@proton.me>
  • Loading branch information
ff137 committed May 31, 2024
1 parent 83b48f6 commit 9ac2750
Showing 1 changed file with 9 additions and 3 deletions.
12 changes: 9 additions & 3 deletions aries_cloudagent/storage/askar.py
Original file line number Diff line number Diff line change
Expand Up @@ -185,10 +185,16 @@ async def find_paginated_records(
offset: The offset to start retrieving records from
options: Additional options for the query
"""
for_update = bool(options and options.get("forUpdate"))
results = []
async for row in self._session.store.scan(
type_filter, tag_query, limit=limit, offset=offset, for_update=for_update

profile = self._session.profile
opened_store: Store = profile.opened.store
async for row in opened_store.scan(
category=type_filter,
tag_filter=tag_query,
limit=limit,
offset=offset,
profile=profile.settings.get("wallet.askar_profile"),
):
results += (
StorageRecord(
Expand Down

0 comments on commit 9ac2750

Please sign in to comment.