Print coro infos on get_client not found error
This commit is contained in:
parent
7ae2ae6cd7
commit
94a623f677
|
@ -6,7 +6,6 @@ import os
|
||||||
import re
|
import re
|
||||||
import sys
|
import sys
|
||||||
import time
|
import time
|
||||||
import traceback
|
|
||||||
from datetime import datetime
|
from datetime import datetime
|
||||||
from pathlib import Path
|
from pathlib import Path
|
||||||
from typing import Any, DefaultDict, Dict, List, Optional, Set, Tuple, Union
|
from typing import Any, DefaultDict, Dict, List, Optional, Set, Tuple, Union
|
||||||
|
@ -337,7 +336,7 @@ class Backend:
|
||||||
await asyncio.gather(*tasks)
|
await asyncio.gather(*tasks)
|
||||||
|
|
||||||
|
|
||||||
async def get_client(self, user_id: str) -> MatrixClient:
|
async def get_client(self, user_id: str, _debug_info=None) -> MatrixClient:
|
||||||
"""Wait until a `MatrixClient` is registered in model and return it."""
|
"""Wait until a `MatrixClient` is registered in model and return it."""
|
||||||
|
|
||||||
failures = 0
|
failures = 0
|
||||||
|
@ -348,8 +347,8 @@ class Backend:
|
||||||
|
|
||||||
if failures and failures % 100 == 0: # every 10s except first time
|
if failures and failures % 100 == 0: # every 10s except first time
|
||||||
log.warning(
|
log.warning(
|
||||||
"Client %r not found after %ds, stack trace:\n%s",
|
"Client %r not found after %ds, _debug_info:\n%r",
|
||||||
user_id, failures / 10, traceback.format_stack(),
|
user_id, failures / 10, _debug_info,
|
||||||
)
|
)
|
||||||
|
|
||||||
await asyncio.sleep(0.1)
|
await asyncio.sleep(0.1)
|
||||||
|
|
|
@ -38,7 +38,7 @@ Python {
|
||||||
) {
|
) {
|
||||||
const future = makeFuture()
|
const future = makeFuture()
|
||||||
|
|
||||||
callCoro("get_client", [accountId], () => {
|
callCoro("get_client", [accountId, [name, args]], () => {
|
||||||
const uuid = accountId + "." + name + "." + CppUtils.uuid()
|
const uuid = accountId + "." + name + "." + CppUtils.uuid()
|
||||||
|
|
||||||
Globals.pendingCoroutines[uuid] = {onSuccess, onError}
|
Globals.pendingCoroutines[uuid] = {onSuccess, onError}
|
||||||
|
|
Loading…
Reference in New Issue
Block a user