Skip to content

Commit 137dd38

Browse files
loewenheimpriscilawebdev
authored andcommitted
ref(proguard): Remove separate queue (#74198)
We stopped routing events to the `process_event_proguard` task (and therefore the `events.process_event_proguard` queue) in #74075. The `store.separate-proguard-queue-rate` option was removed from the options automator in getsentry/sentry-options-automator#1895.
1 parent 3069174 commit 137dd38

File tree

3 files changed

+0
-46
lines changed

3 files changed

+0
-46
lines changed

src/sentry/conf/server.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -866,7 +866,6 @@ def SOCIAL_AUTH_DEFAULT_USERNAME() -> str:
866866
Queue("email.inbound", routing_key="email.inbound"),
867867
Queue("events.preprocess_event", routing_key="events.preprocess_event"),
868868
Queue("events.process_event", routing_key="events.process_event"),
869-
Queue("events.process_event_proguard", routing_key="events.process_event_proguard"),
870869
Queue(
871870
"events.reprocessing.preprocess_event", routing_key="events.reprocessing.preprocess_event"
872871
),

src/sentry/options/defaults.py

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -644,15 +644,6 @@
644644
flags=FLAG_PRIORITIZE_DISK | FLAG_AUTOMATOR_MODIFIABLE,
645645
)
646646

647-
# The fraction of prooguard events that will be routed to the
648-
# separate `store.process_event_proguard` queue
649-
# TODO: Unused, remove this.
650-
register(
651-
"store.separate-proguard-queue-rate",
652-
default=0.0,
653-
flags=FLAG_AUTOMATOR_MODIFIABLE | FLAG_MODIFIABLE_RATE,
654-
)
655-
656647
# Query and supply Bundle Indexes to Symbolicator SourceMap processing
657648
register(
658649
"symbolicator.sourcemaps-bundle-index-sample-rate", default=0.0, flags=FLAG_AUTOMATOR_MODIFIABLE

src/sentry/tasks/store.py

Lines changed: 0 additions & 36 deletions
Original file line numberDiff line numberDiff line change
@@ -459,42 +459,6 @@ def process_event(
459459
)
460460

461461

462-
# TODO: Unused, remove this.
463-
@instrumented_task(
464-
name="sentry.tasks.store.process_event_proguard",
465-
queue="events.process_event_proguard",
466-
time_limit=65,
467-
soft_time_limit=60,
468-
silo_mode=SiloMode.REGION,
469-
)
470-
def process_event_proguard(
471-
cache_key: str,
472-
start_time: float | None = None,
473-
event_id: str | None = None,
474-
data_has_changed: bool = False,
475-
from_symbolicate: bool = False,
476-
has_attachments: bool = False,
477-
**kwargs: Any,
478-
) -> None:
479-
"""
480-
Handles event processing (for those events that need it)
481-
482-
:param string cache_key: the cache key for the event data
483-
:param int start_time: the timestamp when the event was ingested
484-
:param string event_id: the event identifier
485-
:param boolean data_has_changed: set to True if the event data was changed in previous tasks
486-
"""
487-
return do_process_event(
488-
cache_key=cache_key,
489-
start_time=start_time,
490-
event_id=event_id,
491-
from_reprocessing=False,
492-
data_has_changed=data_has_changed,
493-
from_symbolicate=from_symbolicate,
494-
has_attachments=has_attachments,
495-
)
496-
497-
498462
@instrumented_task(
499463
name="sentry.tasks.store.process_event_from_reprocessing",
500464
queue="events.reprocessing.process_event",

0 commit comments

Comments
 (0)