libervia-backend: libervia/backend/plugins/plugin_misc

plugin identity: add a timeout when getting identities.

comparison

equal deleted inserted replaced

-:ed683d56b64c
+:ec9583cac6c2
 from collections import namedtuple
 import io
 from pathlib import Path
 from base64 import b64encode
 import hashlib
-from typing import Any, Coroutine, Dict, List, Optional, Union
+from typing import Any, Coroutine, Dict, List, Optional, Union, cast
-from twisted.internet import defer, threads
+from twisted.internet import defer, reactor, threads
+from twisted.internet.interfaces import IReactorCore
 from twisted.words.protocols.jabber import jid
 from libervia.backend.core import exceptions
 from libervia.backend.core.constants import Const as C
 from libervia.backend.core.i18n import _
 entity=entity_jid,
 metadata_filter=metadata_filter,
 )
 )
 )
-identities_result = await defer.DeferredList(get_identity_list)
+deferred_list = defer.DeferredList(get_identity_list)
+deferred_list.addTimeout(5, cast(IReactorCore, reactor))
+identities_result = await deferred_list
 for idx, (success, identity) in enumerate(identities_result):
 entity_jid = entities[idx]
 if not success:
 log.warning(f"Can't get identity for {entity_jid}")
 else:

Mercurial > libervia-backend