@@ -1212,10 +1212,16 @@ def __init__(self, session_options: Optional[Options] = None):
1212
1212
1213
1213
self ._tasks : Set [Task [None ]] = set ()
1214
1214
1215
+ options : Sequence [tuple [str , Any ]] = [
1216
+ ("grpc.min_reconnect_backoff_ms" , 1100 ),
1217
+ ("grpc.max_reconnect_backoff_ms" , 3000 ),
1218
+ ("grpc.lb_policy_name" , "round_robin" ),
1219
+ ]
1220
+
1215
1221
if self ._session_options .tls_options is None :
1216
1222
self ._channel : grpc .aio .Channel = grpc .aio .insecure_channel (
1217
1223
self ._session_options .address ,
1218
- options = None
1224
+ options = options
1219
1225
if self ._session_options .channel_options is None
1220
1226
else self ._session_options .channel_options ,
1221
1227
interceptors = interceptors ,
@@ -1225,7 +1231,7 @@ def __init__(self, session_options: Optional[Options] = None):
1225
1231
self ._channel = grpc .aio .secure_channel (
1226
1232
self ._session_options .address ,
1227
1233
creds ,
1228
- options = None
1234
+ options = options
1229
1235
if self ._session_options .channel_options is None
1230
1236
else self ._session_options .channel_options ,
1231
1237
interceptors = interceptors ,
0 commit comments