Revert "add support for awx-manage run_callback_receiver --status"

This commit is contained in:
Ryan Petrello
2019-10-18 09:49:02 -04:00
committed by GitHub
parent 0012602b30
commit d01088d33e
5 changed files with 7 additions and 39 deletions

View File

@@ -5,8 +5,6 @@ from django.conf import settings
from django.core.management.base import BaseCommand
from kombu import Exchange, Queue
from awx.main.dispatch import get_local_queuename
from awx.main.dispatch.control import Control
from awx.main.dispatch.kombu import Connection
from awx.main.dispatch.worker import AWXConsumer, CallbackBrokerWorker
@@ -19,20 +17,7 @@ class Command(BaseCommand):
'''
help = 'Launch the job callback receiver'
def add_arguments(self, parser):
parser.add_argument('--status', dest='status', action='store_true',
help='print the internal state of any running callback receiver')
def handle(self, *arg, **options):
control_routing_key = 'callback_receiver-{}-control'.format(get_local_queuename())
if options.get('status'):
print(Control(
'callback_receiver',
queuename=settings.CALLBACK_QUEUE,
routing_key=control_routing_key
).status())
return
with Connection(settings.BROKER_URL) as conn:
consumer = None
try:
@@ -44,9 +29,8 @@ class Command(BaseCommand):
Queue(
settings.CALLBACK_QUEUE,
Exchange(settings.CALLBACK_QUEUE, type='direct'),
routing_key=key
routing_key=settings.CALLBACK_QUEUE
)
for key in [settings.CALLBACK_QUEUE, control_routing_key]
]
)
consumer.run()