File tree 1 file changed +3
-3
lines changed
src/sentry/monitors/consumers
1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -1057,7 +1057,7 @@ def process_single(message: Message[KafkaPayload | FilteredPayload]) -> None:
1057
1057
class StoreMonitorCheckInStrategyFactory (ProcessingStrategyFactory [KafkaPayload ]):
1058
1058
parallel_executor : ThreadPoolExecutor | None = None
1059
1059
1060
- parallel = False
1060
+ batched_parallel = False
1061
1061
"""
1062
1062
Does the consumer process unrelated check-ins in parallel?
1063
1063
"""
@@ -1080,7 +1080,7 @@ def __init__(
1080
1080
max_workers : int | None = None ,
1081
1081
) -> None :
1082
1082
if mode == "batched-parallel" :
1083
- self .parallel = True
1083
+ self .batched_parallel = True
1084
1084
self .parallel_executor = ThreadPoolExecutor (max_workers = max_workers )
1085
1085
1086
1086
if max_batch_size is not None :
@@ -1115,7 +1115,7 @@ def create_with_partitions(
1115
1115
commit : Commit ,
1116
1116
partitions : Mapping [Partition , int ],
1117
1117
) -> ProcessingStrategy [KafkaPayload ]:
1118
- if self .parallel :
1118
+ if self .batched_parallel :
1119
1119
return self .create_parallel_worker (commit )
1120
1120
else :
1121
1121
return self .create_synchronous_worker (commit )
You can’t perform that action at this time.
0 commit comments