Skip to content

Commit fe08f81

Browse files
author
extreme4all
committed
fix: add delay for batch processing when below max messages threshold
1 parent a7b3cb7 commit fe08f81

File tree

1 file changed

+3
-0
lines changed
  • bases/bot_detector/worker_hiscore

1 file changed

+3
-0
lines changed

bases/bot_detector/worker_hiscore/core.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -80,6 +80,9 @@ async def consume_many_task(
8080
await asyncio.sleep(15)
8181
continue
8282

83+
if len(batch) < max_messages:
84+
await asyncio.sleep(15)
85+
8386
_, error = await insert_batch(
8487
highscore_repo=highscore_repo,
8588
player_repo=player_repo,

0 commit comments

Comments
 (0)