improve style.
This commit is contained in:
parent
329d682f4c
commit
a1f94078c4
@ -49,14 +49,14 @@ class PersistMethod:
|
|||||||
|
|
||||||
async def diff_async(differ, last_text, text):
|
async def diff_async(differ, last_text, text):
|
||||||
try:
|
try:
|
||||||
result = await asyncio.wait_for(
|
return await asyncio.wait_for(
|
||||||
asyncio.to_thread(differ.inline_json_diff, last_text, text),
|
asyncio.to_thread(differ.inline_json_diff, last_text, text),
|
||||||
timeout=DIFF_TIMEOUT
|
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 None
|
||||||
return result
|
|
||||||
|
|
||||||
def calculate_persistence(tokens_added):
|
def calculate_persistence(tokens_added):
|
||||||
return (sum([(len(x.revisions) - 1) for x in tokens_added]), len(tokens_added))
|
return (sum([(len(x.revisions) - 1) for x in tokens_added]), len(tokens_added))
|
||||||
|
Loading…
Reference in New Issue
Block a user