Skip to content

Commit

Permalink
🐛 (sync/aleph) Fix things
Browse files Browse the repository at this point in the history
  • Loading branch information
simonwoerpel committed Jan 8, 2025
1 parent e03e4d4 commit 79266e3
Showing 1 changed file with 5 additions and 2 deletions.
7 changes: 5 additions & 2 deletions leakrfc/sync/aleph.py
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ def make_parent_cache_key(
) -> str | None:
parts = [str(Path(key).parent)]
if prefix:
parts = prefix + parts
parts = [prefix] + parts
return aleph.make_aleph_cache_key(self, "folder", *parts, "created")


Expand Down Expand Up @@ -76,7 +76,10 @@ def queue_tasks_from_version(self, version: str) -> datetime:
self.log_info("Loading documents diff ...", version=version)
now = datetime.now()
for key in logged_io_items(
self.dataset.documents.get_keys_added(version), "", "Load", "Document"
self.dataset.documents.get_keys_added(version),
uri=version,
action="Load",
item_name="Document",
):
self.queue_task(self.dataset.lookup_file(key))
return now
Expand Down

0 comments on commit 79266e3

Please sign in to comment.