small fixes

Author: wedamija

src/sentry/processing_errors/eap/producer.py

@@ -24,7 +24,6 @@
 logger = logging.getLogger(__name__)
 
 PROCESSING_ERROR_NAMESPACE = uuid.UUID("a4d8f4e2-1b3c-4a9d-9e1f-5c2b1a0d7f6e")
-
 EAP_ITEMS_CODEC: Codec[TraceItem] = get_topic_codec(Topic.SNUBA_ITEMS)
 
 
@@ -100,7 +99,7 @@ def produce_processing_errors_to_eap(
                 organization_id=project.organization_id,
                 project_id=project.id,
                 item_id=item_id,
-                item_type=TraceItemType.TRACE_ITEM_TYPE_PREPROD,  # TODO: switch to TRACE_ITEM_TYPE_PROCESSING_ERROR once sentry-protos is updated
+                item_type=TraceItemType.TRACE_ITEM_TYPE_PROCESSING_ERROR,
                 timestamp=timestamp,
                 trace_id=trace_id,
                 retention_days=retention_days,

src/sentry/tasks/post_process.py

@@ -20,6 +20,7 @@
 from sentry.issues.grouptype import GroupCategory
 from sentry.issues.issue_occurrence import IssueOccurrence
 from sentry.killswitches import killswitch_matches_context
+from sentry.processing_errors.eap.producer import produce_processing_errors_to_eap
 from sentry.replays.lib.event_linking import transform_event_for_linking_payload
 from sentry.replays.lib.kafka import initialize_replays_publisher
 from sentry.seer.autofix.constants import FixabilityScoreThresholds
@@ -1291,8 +1292,6 @@ def process_processing_errors_eap(job: PostProcessJob):
     if not processing_errors:
         return
 
-    from sentry.processing_errors.eap.producer import produce_processing_errors_to_eap
-
     produce_processing_errors_to_eap(event.project, event.data, processing_errors)