Skip to content

Commit 3a95be1

Browse files
getsentry-botevanpurkhiser
authored andcommitted
Reapply "ref(crons): Remove parallel mode (batched-parallel replaced it)"
This reverts commit 592ce76.
1 parent 592ce76 commit 3a95be1

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

Diff for: src/sentry/consumers/__init__.py

+2-2
Original file line numberDiff line numberDiff line change
@@ -109,8 +109,8 @@ def ingest_monitors_options() -> list[click.Option]:
109109
options = [
110110
click.Option(
111111
["--mode", "mode"],
112-
type=click.Choice(["serial", "parallel", "batched-parallel"]),
113-
default="parallel",
112+
type=click.Choice(["serial", "batched-parallel"]),
113+
default="batched-parallel",
114114
help="The mode to process check-ins in. Parallel uses multithreading.",
115115
),
116116
click.Option(

Diff for: src/sentry/monitors/consumers/monitor_consumer.py

+2-2
Original file line numberDiff line numberDiff line change
@@ -1074,12 +1074,12 @@ class StoreMonitorCheckInStrategyFactory(ProcessingStrategyFactory[KafkaPayload]
10741074

10751075
def __init__(
10761076
self,
1077-
mode: Literal["batched-parallel", "parallel", "serial"] | None = None,
1077+
mode: Literal["batched-parallel", "serial"] | None = None,
10781078
max_batch_size: int | None = None,
10791079
max_batch_time: int | None = None,
10801080
max_workers: int | None = None,
10811081
) -> None:
1082-
if mode == "batched-parallel" or mode == "parallel":
1082+
if mode == "batched-parallel":
10831083
self.parallel = True
10841084
self.parallel_executor = ThreadPoolExecutor(max_workers=max_workers)
10851085

0 commit comments

Comments
 (0)