fix asyncio bug.

This commit is contained in:
Nathan TeBlunthuis 2025-08-07 09:10:16 -07:00
parent 19f67b3679
commit 329d682f4c

View File

@ -48,10 +48,11 @@ class PersistMethod:
async def diff_async(differ, last_text, text): async def diff_async(differ, last_text, text):
async def _diff():
return differ.inline_json_diff(last_text, text)
try: try:
result = await asyncio.wait_for(_diff(), DIFF_TIMEOUT) result = await asyncio.wait_for(
asyncio.to_thread(differ.inline_json_diff, last_text, text),
timeout=DIFF_TIMEOUT
)
except TimeoutError: except TimeoutError:
print(f"WARNING! wikidiff2 timeout for rev: {row_buffer['revid'][i]}. Falling back to default limits.", file=sys.stderr) print(f"WARNING! wikidiff2 timeout for rev: {row_buffer['revid'][i]}. Falling back to default limits.", file=sys.stderr)
return return