This should be a dispatcher task

Author: AlanCoding

ansible_base/task/tasks.py

@@ -1,13 +1,15 @@
 import logging
 
 from dispatcher.utils import resolve_callable
+from dispatcher.publish import task
 from django.db import transaction
 
 from ansible_base.task.models import TASK_STATES, Task
 
 logger = logging.getLogger(__name__)
 
 
+@task(queue='dab_broadcast')
 def run_task_from_queue():
     with transaction.atomic():
         task = Task.objects.filter(state=TASK_STATES.WAITING).select_for_update().first()