Skip to content

Commit

Permalink
sleep longer
Browse files Browse the repository at this point in the history
  • Loading branch information
extreme4all committed Feb 6, 2024
1 parent a89f78a commit b975f1b
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/jobs/kafka/players/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -154,7 +154,7 @@ async def get_data(receive_queue: Queue, consumer:AIOKafkaConsumer):

if lag > 100_000:
logger.info(f"lag is to high: {lag=}")
await asyncio.sleep(5)
await asyncio.sleep(60)
continue

players, error = await get_request(url=url, params=params, headers=headers)
Expand Down

0 comments on commit b975f1b

Please sign in to comment.