From b4123c479dd0f51bb46cc009ac429d0e0e0a3f52 Mon Sep 17 00:00:00 2001 From: Jylpah Date: Sat, 8 Feb 2020 12:11:02 +0200 Subject: [PATCH] Set max size for replay queue --- analyze_wotb_replays.py | 12 ++---------- 1 file changed, 2 insertions(+), 10 deletions(-) diff --git a/analyze_wotb_replays.py b/analyze_wotb_replays.py index 04a4bb8..9296bc5 100644 --- a/analyze_wotb_replays.py +++ b/analyze_wotb_replays.py @@ -422,9 +422,10 @@ async def main(argv): bu.debug('No DB in use') try: - replayQ = asyncio.Queue() + replayQ = asyncio.Queue(maxsize=1000) reader_tasks = [] # Make replay Queue + scanner_task = asyncio.create_task(mk_replayQ(replayQ, args.files)) bu.debug('Replay scanner started') # Start tasks to process the Queue @@ -448,15 +449,6 @@ async def main(argv): results.extend(res[0]) players.update(res[1]) - # ## Remove battle_time from the player:tank data in case DB is not in use - # if db == None: - # players_tmp = set() - # for player in players: - # #bu.debug('playerID: ' + player + ' ==> ' + prune_stat_id(player)) - # players_tmp.add(prune_stat_id(player)) - # #bu.debug(str(len(players_tmp))) - # players = players_tmp - (player_stats, stat_id_map) = await process_player_stats(players, TASK_N, args, db) bu.verbose('') bu.debug('Number of player stats: ' + str(len(player_stats)))