diff --git a/src/dispatch/cli.py b/src/dispatch/cli.py
index 0ccf135ad224..7c6836c3b710 100644
--- 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
index f2a1c770b354..fb6902e83cc1 100644
--- 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
deleted file mode 100644
index f09d5415f396..000000000000
--- a/src/dispatch/signal/scheduled.py
+++ /dev/null
@@ -1,50 +0,0 @@
-"""
-.. module: dispatch.signal.scheduled
-    :platform: Unix
-    :copyright: (c) 2022 by Netflix Inc., see AUTHORS for more
-    :license: Apache, see LICENSE for more details.
-"""
-import logging
-
-from schedule import every
-
-from dispatch.database.core import SessionLocal
-from dispatch.decorators import scheduled_project_task, timer
-from dispatch.plugin import service as plugin_service
-from dispatch.project.models import Project
-from dispatch.scheduler import scheduler
-from dispatch.signal import flows as signal_flows
-
-log = logging.getLogger(__name__)
-
-
-# TODO do we want per signal source flexibility?
-@scheduler.add(every(1).minutes, name="signal-consume")
-@timer
-@scheduled_project_task
-def consume_signals(db_session: SessionLocal, project: Project):
-    """Consume signals from external sources."""
-    plugins = plugin_service.get_active_instances(
-        db_session=db_session, plugin_type="signal-consumer", project_id=project.id
-    )
-
-    if not plugins:
-        log.debug(
-            "No signals consumed. No signal-consumer plugins enabled. Project: {project.name}. Organization: {project.organization.name}"
-        )
-        return
-
-    for plugin in plugins:
-        log.debug(f"Consuming signals using signal-consumer plugin: {plugin.plugin.slug}")
-        signal_instances = plugin.instance.consume()
-        for signal_instance_data in signal_instances:
-            log.info(f"Attempting to process the following signal: {signal_instance_data}")
-            try:
-                signal_flows.create_signal_instance(
-                    db_session=db_session,
-                    project=project,
-                    signal_instance_data=signal_instance_data,
-                )
-            except Exception as e:
-                log.debug(signal_instance_data)
-                log.exception(e)