GonnaHetzMe/blitz-tools
0
0 Fork 0
mirror of https://github.com/Jylpah/blitz-tools.git synced 2026-10-25 02:59:53 +01:00
Code Issues Projects Releases Wiki Activity

Update warning messages

Browse Source
This commit is contained in:
Jylpah committed 2020-07-10 12:29:21 +03:00
1 parent 25b4f75533
commit 001d73f3ae
1 file changed
+3 -4
Download Patch File Download Diff File Expand all files Collapse all files
analyze_wotb_replays.py
+3 -4
View File
@@ -1198,7 +1198,6 @@ async def mk_readerQ_item(replay_json) -> list:
async def replay_reader(queue: asyncio.Queue, readerID: int, args : argparse.Namespace): async def replay_reader(queue: asyncio.Queue, readerID: int, args : argparse.Namespace):
"""Async Worker to process the replay queue""" """Async Worker to process the replay queue"""
#global SKIPPED_N #global SKIPPED_N
# account_id = args.account_id
results = [] results = []
playerstanks = set() playerstanks = set()
try: try:
@@ -1208,9 +1207,9 @@ async def replay_reader(queue: asyncio.Queue, readerID: int, args : argparse.Nam
replayID = item[1] replayID = item[1]
try: try:
msg_str = 'Replay[' + str(replayID) + ']:' msg_str = 'Replay[' + str(replayID) + ']: '
if replay_json == None: if replay_json == None:
bu.verbose(msg_str + 'Replay is empty. Skipping.' ) bu.warning(msg_str + 'Invalid replay. Skipping.' )
#SKIPPED_N += 1 #SKIPPED_N += 1
queue.task_done() queue.task_done()
continue continue
@@ -1220,7 +1219,7 @@ async def replay_reader(queue: asyncio.Queue, readerID: int, args : argparse.Nam
result = await read_replay_JSON(replay_json, args) result = await read_replay_JSON(replay_json, args)
bu.print_progress() bu.print_progress()
if result == None: if result == None:
bu.debug('Replay[' + str(replayID) + ']: Invalid replay', id=readerID) bu.warning(msg_str + 'Invalid replay', id=readerID)
queue.task_done() queue.task_done()
continue continue