Skip to content

Commit

Permalink
Oops
Browse files Browse the repository at this point in the history
  • Loading branch information
psrok1 committed May 15, 2024
1 parent de6ee9a commit 794a0a0
Showing 1 changed file with 4 additions and 2 deletions.
6 changes: 4 additions & 2 deletions karton/core/backend.py
Original file line number Diff line number Diff line change
Expand Up @@ -449,7 +449,7 @@ def get_tasks(
chunk_size,
)
return [
Task.unserialize(task_data, parse_resources=parse_resources)
Task.unserialize(task_data, backend=self, parse_resources=parse_resources)
for chunk in keys
for task_data in self.redis.mget(chunk)
if task_data is not None
Expand All @@ -463,7 +463,9 @@ def _iter_tasks(
) -> Iterator[Task]:
for chunk in chunks_iter(task_keys, chunk_size):
yield from (
Task.unserialize(task_data, parse_resources=parse_resources)
Task.unserialize(
task_data, backend=self, parse_resources=parse_resources
)
for task_data in self.redis.mget(chunk)
if task_data is not None
)
Expand Down

0 comments on commit 794a0a0

Please sign in to comment.