@@ -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