temp

boris · boris · commit 53bf6ffd74e8 · 2022-09-24T16:17:00.000+08:00
diff --git a/google/api_core/retry.py b/google/api_core/retry.py
@@ -61,6 +61,7 @@ def check_if_exists():
 import logging
 import random
 import time
+import threading
 
 import requests.exceptions
 
@@ -145,8 +146,7 @@ def exponential_sleep_generator(initial, maximum, multiplier=_DEFAULT_DELAY_MULT
         # to average out to the delay time.
         res = min(random.uniform(0.0, delay * 2.0), maximum)
         _LOGGER.debug(
-            "exponential_sleep_generator initial: {:.1f}s, maximum: {:.1f}s, multipier: {:1f}s, res:{:1f}s".format(initial, maximum,
-                                                                                                       multiplier, res)
+            f"xxxxx: {threading.current_thread().name} exponential_sleep_generator initial: {initial}s, maximum: {maximum}s, multipier: {multiplier}s, res:{res}s"
         )
         yield res
         delay = delay * multiplier
@@ -192,7 +192,10 @@ def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
 
     for sleep in sleep_generator:
         try:
-            return target()
+            _LOGGER.debug(f"xxxxx: {threading.current_thread().name} before target sleep: {sleep}")
+            res = target()
+            _LOGGER.debug(f"xxxxx: {threading.current_thread().name} res: {res}")
+            return res
 
         # pylint: disable=broad-except
         # This function explicitly must deal with broad exceptions.
