File tree Expand file tree Collapse file tree 1 file changed +5
-5
lines changed
src/sentry/uptime/consumers Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Original file line number Diff line number Diff line change 45
45
send_uptime_config_deletion ,
46
46
update_remote_uptime_subscription ,
47
47
)
48
- from sentry .uptime .types import IncidentStatus , UptimeMonitorMode
48
+ from sentry .uptime .types import DATA_SOURCE_UPTIME_SUBSCRIPTION , IncidentStatus , UptimeMonitorMode
49
49
from sentry .utils import metrics
50
50
from sentry .utils .arroyo_producer import SingletonProducer
51
51
from sentry .utils .kafka_config import get_kafka_producer_cluster_options , get_topic_definition
52
52
from sentry .workflow_engine .models .data_source import DataPacket
53
53
from sentry .workflow_engine .models .detector import Detector
54
- from sentry .workflow_engine .processors .detector import process_detectors
54
+ from sentry .workflow_engine .processors .data_packet import process_data_packets
55
55
56
56
logger = logging .getLogger (__name__ )
57
57
@@ -312,9 +312,9 @@ def handle_active_result(
312
312
subscription = uptime_subscription ,
313
313
metric_tags = metric_tags ,
314
314
)
315
- process_detectors (
316
- DataPacket (source_id = str (uptime_subscription .id ), packet = packet ),
317
- [ detector ] ,
315
+ process_data_packets (
316
+ [ DataPacket (source_id = str (uptime_subscription .id ), packet = packet )] ,
317
+ DATA_SOURCE_UPTIME_SUBSCRIPTION ,
318
318
)
319
319
320
320
# Bail if we're doing issue creation via detectors, we don't want to
You can’t perform that action at this time.
0 commit comments