Skip to content

Commit 1be6427

Browse files
authored
fix(query-subscriptions-consumer): Revert CLI changes to query subscriptions consumer (#45230)
Reverting the parts of the query subscriptions consumer that were changed in #45182 This was supposed to apply to the post process forwarder instead.
1 parent 0cdbec6 commit 1be6427

File tree

1 file changed

+5
-5
lines changed
  • src/sentry/runner/commands

1 file changed

+5
-5
lines changed

src/sentry/runner/commands/run.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -344,13 +344,13 @@ def cron(**options):
344344
"--commit-batch-size",
345345
default=1000,
346346
type=int,
347-
help="How many messages to process (may or may not result in an enqueued task) before committing offsets.",
347+
help="Deprecated. Remove once no longer passed in production.",
348348
)
349349
@click.option(
350350
"--commit-batch-timeout-ms",
351351
default=5000,
352352
type=int,
353-
help="Time (in milliseconds) to wait before closing current batch and committing offsets.",
353+
help="Deprecated. Remove once no longer passed in production.",
354354
)
355355
@click.option(
356356
"--concurrency",
@@ -405,15 +405,15 @@ def post_process_forwarder(**options):
405405
@click.option("--topic", default=None, help="Topic to get subscription updates from.")
406406
@click.option(
407407
"--commit-batch-size",
408-
default=1000,
408+
default=100,
409409
type=int,
410-
help="Deprecated. Remove once no longer passed in production.",
410+
help="How many messages to process before committing offsets.",
411411
)
412412
@click.option(
413413
"--commit-batch-timeout-ms",
414414
default=5000,
415415
type=int,
416-
help="Deprecated. Remove once no longer passed in production.",
416+
help="Time (in milliseconds) to wait before closing current batch and committing offsets.",
417417
)
418418
@click.option(
419419
"--initial-offset-reset",

0 commit comments

Comments
 (0)