Skip to content

Commit 77f9b12

Browse files
feat(uptime): Directly call process_detectors (#94992)
We already have the Detector object, there's no reason we need to look it up again via the process_data_packets interface.
1 parent 93a870d commit 77f9b12

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

src/sentry/uptime/consumers/results_consumer.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -45,13 +45,13 @@
4545
send_uptime_config_deletion,
4646
update_remote_uptime_subscription,
4747
)
48-
from sentry.uptime.types import DATA_SOURCE_UPTIME_SUBSCRIPTION, IncidentStatus, UptimeMonitorMode
48+
from sentry.uptime.types import IncidentStatus, UptimeMonitorMode
4949
from sentry.utils import metrics
5050
from sentry.utils.arroyo_producer import SingletonProducer
5151
from sentry.utils.kafka_config import get_kafka_producer_cluster_options, get_topic_definition
5252
from sentry.workflow_engine.models.data_source import DataPacket
5353
from sentry.workflow_engine.models.detector import Detector
54-
from sentry.workflow_engine.processors.data_packet import process_data_packets
54+
from sentry.workflow_engine.processors.detector import process_detectors
5555

5656
logger = logging.getLogger(__name__)
5757

@@ -312,9 +312,9 @@ def handle_active_result(
312312
subscription=uptime_subscription,
313313
metric_tags=metric_tags,
314314
)
315-
process_data_packets(
316-
[DataPacket(source_id=str(uptime_subscription.id), packet=packet)],
317-
DATA_SOURCE_UPTIME_SUBSCRIPTION,
315+
process_detectors(
316+
DataPacket(source_id=str(uptime_subscription.id), packet=packet),
317+
[detector],
318318
)
319319

320320
# Bail if we're doing issue creation via detectors, we don't want to

0 commit comments

Comments
 (0)