Skip to content

Commit 8cdfd9b

Browse files
committed
[Community] fix paginated fetch
1 parent cd35720 commit 8cdfd9b

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

octobot/community/supabase_backend/community_supabase_client.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -431,7 +431,11 @@ async def _fetch_paginated_history(
431431
request = request.range(offset, offset+max_size)
432432
fetched_elements = (await request.execute()).data
433433
total_elements += fetched_elements
434-
if len(fetched_elements) < max_size or (max_size == 0 and len(fetched_elements) == total_elements_count):
434+
if(
435+
len(fetched_elements) == 0 or
436+
len(fetched_elements) < max_size or
437+
(max_size == 0 and len(fetched_elements) == total_elements_count)
438+
):
435439
# fetched everything
436440
break
437441
offset += len(fetched_elements)

0 commit comments

Comments
 (0)