File tree Expand file tree Collapse file tree 1 file changed +7
-2
lines changed Expand file tree Collapse file tree 1 file changed +7
-2
lines changed Original file line number Diff line number Diff line change 23
23
24
24
logger = logging .getLogger ("sentry.taskworker.client" )
25
25
26
+ MAX_ACTIVATION_SIZE = 1024 * 1024 * 10
27
+ """Max payload size we will process."""
28
+
26
29
27
30
class ClientCallDetails (grpc .ClientCallDetails ):
28
31
"""
@@ -101,9 +104,11 @@ def __init__(
101
104
)
102
105
103
106
grpc_config = options .get ("taskworker.grpc_service_config" )
104
- self ._grpc_options = []
107
+ self ._grpc_options : list [tuple [str , Any ]] = [
108
+ ("grpc.max_receive_message_length" , MAX_ACTIVATION_SIZE )
109
+ ]
105
110
if grpc_config :
106
- self ._grpc_options = [( "grpc.service_config" , grpc_config )]
111
+ self ._grpc_options . append (( "grpc.service_config" , grpc_config ))
107
112
108
113
self ._cur_host = random .choice (self ._hosts )
109
114
self ._host_to_stubs : dict [str , ConsumerServiceStub ] = {
You can’t perform that action at this time.
0 commit comments