Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
10 changes: 5 additions & 5 deletions src/sentry/runner/commands/run.py
Original file line number Diff line number Diff line change
Expand Up @@ -344,13 +344,13 @@ def cron(**options):
"--commit-batch-size",
default=1000,
type=int,
help="How many messages to process (may or may not result in an enqueued task) before committing offsets.",
help="Deprecated. Remove once no longer passed in production.",
)
@click.option(
"--commit-batch-timeout-ms",
default=5000,
type=int,
help="Time (in milliseconds) to wait before closing current batch and committing offsets.",
help="Deprecated. Remove once no longer passed in production.",
)
@click.option(
"--concurrency",
Expand Down Expand Up @@ -405,15 +405,15 @@ def post_process_forwarder(**options):
@click.option("--topic", default=None, help="Topic to get subscription updates from.")
@click.option(
"--commit-batch-size",
default=1000,
default=100,
type=int,
help="Deprecated. Remove once no longer passed in production.",
help="How many messages to process before committing offsets.",
)
@click.option(
"--commit-batch-timeout-ms",
default=5000,
type=int,
help="Deprecated. Remove once no longer passed in production.",
help="Time (in milliseconds) to wait before closing current batch and committing offsets.",
)
@click.option(
"--initial-offset-reset",
Expand Down