diff --git a/src/sentry/tasks/post_process.py b/src/sentry/tasks/post_process.py index 6bfda95ca8c9c6..e49d73fb9977d6 100644 --- a/src/sentry/tasks/post_process.py +++ b/src/sentry/tasks/post_process.py @@ -659,32 +659,6 @@ def get_event_raise_exception() -> Event: tags=metric_tags, ) - if not is_reprocessed: - received_at = event.data.get("received") - saved_at = event.data.get("nodestore_insert") - post_processed_at = time() - - if saved_at: - metrics.timing( - "events.saved_to_post_processed", - post_processed_at - saved_at, - instance=event.data["platform"], - tags=metric_tags, - ) - else: - metrics.incr("events.missing_nodestore_insert", tags=metric_tags) - - if received_at: - metrics.timing( - "events.time-to-post-process", - post_processed_at - received_at, - instance=event.data["platform"], - tags=metric_tags, - ) - - else: - metrics.incr("events.missing_received", tags=metric_tags) - def run_post_process_job(job: PostProcessJob) -> None: group_event = job["event"] diff --git a/src/sentry/utils/event.py b/src/sentry/utils/event.py index 31b9456862e978..86e2271fd5fa48 100644 --- a/src/sentry/utils/event.py +++ b/src/sentry/utils/event.py @@ -109,6 +109,7 @@ def track_event_since_received( received_at = event_data.get("received") if not received_at: + metrics.incr("events.missing_received", tags=tags) return platform = event_data.get("platform") diff --git a/tests/sentry/tasks/test_post_process.py b/tests/sentry/tasks/test_post_process.py index f51074e9003ba1..c83671a7dec94b 100644 --- a/tests/sentry/tasks/test_post_process.py +++ b/tests/sentry/tasks/test_post_process.py @@ -191,28 +191,6 @@ def test_processing_cache_cleared_with_commits(self) -> None: ) assert event_processing_store.get(cache_key) is None - @patch("sentry.utils.metrics.timing") - @patch("sentry.tasks.post_process.logger") - def test_time_to_process_metric( - self, logger_mock: MagicMock, metric_timing_mock: MagicMock - ) -> None: - event = self.create_event(data={}, project_id=self.project.id) - self.call_post_process_group( - is_new=True, - is_regression=False, - is_new_group_environment=True, - event=event, - ) - metric_timing_mock.assert_any_call( - "events.time-to-post-process", - mock.ANY, - instance=mock.ANY, - tags={"occurrence_type": mock.ANY}, - ) - assert "tasks.post_process.old_time_to_post_process" not in [ - args[0] for args in logger_mock.warning.call_args_list - ] - class DeriveCodeMappingsProcessGroupTestMixin(BasePostProgressGroupMixin): def _create_event(