@@ -111,9 +111,11 @@ def _retry_call(
111
111
112
112
while True :
113
113
try :
114
+ _LOGGER .debug (f"client._retry_call.start!!!" )
114
115
response_or_iterator = continuation (
115
116
client_call_details , request_or_iterator
116
117
)
118
+ _LOGGER .debug (f"client._retry_call.response_or_iterator Success!!!" )
117
119
118
120
if is_stream :
119
121
response_or_iterator = self ._generate_response (response_or_iterator )
@@ -123,7 +125,11 @@ def _retry_call(
123
125
return response_or_iterator
124
126
125
127
except Exception as e :
128
+ _LOGGER .debug (f"client._retry_call.Exception: { e } " )
126
129
if e .error_code == "ERROR_GRPC_CONNECTION" :
130
+ _LOGGER .debug (
131
+ f"client._retry_call.retry_call: { retries } || _MAX_RETRIES: { _MAX_RETRIES } "
132
+ )
127
133
if retries >= _MAX_RETRIES :
128
134
channel = e .meta .get ("channel" )
129
135
if channel in _GRPC_CHANNEL :
@@ -160,7 +166,9 @@ def _intercept_call(
160
166
is_response_stream ,
161
167
)
162
168
163
- def intercept_unary_unary (self , continuation , client_call_details , request ):
169
+ def intercept_unary_unary (
170
+ self , continuation : object , client_call_details : object , request : object
171
+ ) -> object :
164
172
return self ._intercept_call (
165
173
continuation , client_call_details , request , False , False
166
174
)
0 commit comments