Removes scheduled consumers in favor of long running processes

Netflix · Sep 29, 2023 · 9a51975 · 9a51975
1 parent 44a45c2
commit 9a51975
Show file tree

Hide file tree

Showing 3 changed files with 1 addition and 52 deletions.
diff --git a/src/dispatch/cli.py b/src/dispatch/cli.py
@@ -627,7 +627,6 @@ def dispatch_scheduler():
     from .incident.scheduled import (
         incident_auto_tagger,  # noqa
     )
-    from .signal.scheduled import consume_signals  # noqa
     from .incident_cost.scheduled import calculate_incidents_response_cost  # noqa
     from .monitor.scheduled import sync_active_stable_monitors  # noqa
     from .report.scheduled import incident_report_reminders  # noqa

diff --git a/src/dispatch/plugins/dispatch_aws/plugin.py b/src/dispatch/plugins/dispatch_aws/plugin.py
@@ -60,7 +60,7 @@ def consume(self, db_session, project):
                             ),
                         )
                         metrics_provider.counter(
-                            "sqs.signal.received",
+                            "aws-sqs-signal-consumer.signal.received",
                             tags={
                                 "signalName": signal_instance.signal.name,
                                 "externalId": signal_instance.signal.external_id,

diff --git a/src/dispatch/signal/scheduled.py b/src/dispatch/signal/scheduled.py