diff --git a/src/jobs/kafka/players/main.py b/src/jobs/kafka/players/main.py index 7c7b333..932da75 100644 --- a/src/jobs/kafka/players/main.py +++ b/src/jobs/kafka/players/main.py @@ -138,7 +138,7 @@ async def get_data(receive_queue: Queue): if today != last_day: logger.info("New day!, resetting player_id to 0") params["player_id"] = 0 - today = last_day + last_day = today if len_players < APPCONFIG.BATCH_SIZE: sleep_time = 300