We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5659767 commit 49c851bCopy full SHA for 49c851b
sdks/python/apache_beam/runners/worker/channel_factory.py
@@ -23,10 +23,10 @@
23
24
class GRPCChannelFactory(grpc.StreamStreamClientInterceptor):
25
DEFAULT_OPTIONS = [
26
- # keep 20 seconds for now. This is needed for other options to work.
27
- ("grpc.keepalive_time_ms", 20000),
28
- # keep 5 minutes for now.
29
- ("grpc.keepalive_timeout_ms", 300000),
+ # Setting keepalive_time_ms is needed for other options to work.
+ ("grpc.keepalive_time_ms", 20_000),
+ # Default: 20s. Increasing to 5 min.
+ ("grpc.keepalive_timeout_ms", 300_000),
30
# Default: 2, set to 0 to allow unlimited pings without data
31
("grpc.http2.max_pings_without_data", 0),
32
# Default: False, set to True to allow keepalive pings when no calls
0 commit comments