diff --git a/src/sentry/tasks/post_process.py b/src/sentry/tasks/post_process.py index dc0cf1bf94794c..ca527bb730c7dc 100644 --- a/src/sentry/tasks/post_process.py +++ b/src/sentry/tasks/post_process.py @@ -1205,8 +1205,8 @@ def process_plugins(job: PostProcessJob) -> None: def process_similarity(job: PostProcessJob) -> None: - if job["is_reprocessed"] or features.has( - "projects:similarity-embeddings", job["event"].group.project + if job["is_reprocessed"] or job["event"].group.project.get_option( + "sentry:similarity_backfill_completed" ): return diff --git a/tests/sentry/tasks/test_post_process.py b/tests/sentry/tasks/test_post_process.py index 80de27eadeb67e..fbab42dff76349 100644 --- a/tests/sentry/tasks/test_post_process.py +++ b/tests/sentry/tasks/test_post_process.py @@ -2436,9 +2436,9 @@ def assert_not_called_with(self, mock_function: Mock): return raise AssertionError("Expected safe_execute to not be called with similarity.record") - @with_feature("projects:similarity-embeddings") @patch("sentry.tasks.post_process.safe_execute") def test_skip_process_similarity(self, mock_safe_execute): + self.project.update_option("sentry:similarity_backfill_completed", int(time.time())) event = self.create_event(data={}, project_id=self.project.id) self.call_post_process_group(