import functools
import os
import sys
+import threading
from pylib import constants
from pylib.device import device_errors
def impl():
return f(*args, **kwargs)
try:
- return timeout_retry.Run(impl, timeout, retries)
+ if isinstance(threading.current_thread(),
+ timeout_retry.TimeoutRetryThread):
+ return impl()
+ else:
+ return timeout_retry.Run(impl, timeout, retries)
except old_errors.WaitForResponseTimedOutError as e:
raise device_errors.CommandTimeoutError(str(e)), None, (
sys.exc_info()[2])