From 19f67b3679686bb90c9be090fc2eceec3f42b7c4 Mon Sep 17 00:00:00 2001 From: Nathan TeBlunthuis Date: Thu, 7 Aug 2025 08:58:45 -0700 Subject: [PATCH] try fixing coro issue. --- src/wikiq/__init__.py | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) diff --git a/src/wikiq/__init__.py b/src/wikiq/__init__.py index 2012e83..7b763c9 100755 --- a/src/wikiq/__init__.py +++ b/src/wikiq/__init__.py @@ -30,7 +30,7 @@ from wikiq.wiki_diff_matcher import WikiDiffMatcher TO_ENCODE = ("title", "editor") PERSISTENCE_RADIUS = 7 -DIFF_TIMEOUT = 60*20 +DIFF_TIMEOUT = 60 from pathlib import Path import pyarrow as pa @@ -52,8 +52,9 @@ async def diff_async(differ, last_text, text): return differ.inline_json_diff(last_text, text) try: result = await asyncio.wait_for(_diff(), DIFF_TIMEOUT) - except TimeoutError as e: - raise e + except TimeoutError: + print(f"WARNING! wikidiff2 timeout for rev: {row_buffer['revid'][i]}. Falling back to default limits.", file=sys.stderr) + return return result def calculate_persistence(tokens_added): @@ -677,10 +678,8 @@ class WikiqParser: last_text = last_rev_text new_diffs = [] for i, text in enumerate(row_buffer["text"]): - try: - diff = asyncio.run(diff_async(differ, last_text, text)) - except TimeoutError: - print(f"WARNING! wikidiff2 timeout for rev: {row_buffer['revid'][i]}. Falling back to default limits.", file=sys.stderr) + diff = asyncio.run(diff_async(differ, last_text, text)) + if diff is None: diff = fast_differ.inline_json_diff(last_text, text) new_diffs.append(diff) last_text = text