diff --git a/awx/main/tasks/receptor.py b/awx/main/tasks/receptor.py
index 81f0c6eb9b..3ec579844e 100644
--- a/awx/main/tasks/receptor.py
+++ b/awx/main/tasks/receptor.py
@@ -28,6 +28,7 @@ from awx.main.utils.common import (
 from awx.main.constants import MAX_ISOLATED_PATH_COLON_DELIMITER
 from awx.main.tasks.signals import signal_state, signal_callback, SignalExit
 from awx.main.models import Instance, InstanceLink, UnifiedJob
+from awx.main.dispatch import get_local_queuename
 from awx.main.dispatch.publish import task
 
 # Receptorctl
@@ -670,7 +671,7 @@ def write_receptor_config():
     links.update(link_state=InstanceLink.States.ESTABLISHED)
 
 
-@task()
+@task(queue=get_local_queuename)
 def wait_for_jobs(hostname):
     node_jobs = UnifiedJob.objects.filter(
         execution_node=hostname,