diff --git a/awx/main/tasks.py b/awx/main/tasks.py index 1e893aaba9..bb0f7275d3 100644 --- a/awx/main/tasks.py +++ b/awx/main/tasks.py @@ -493,12 +493,6 @@ class RunJob(BaseTask): return False elif job.status in ('pending', 'waiting'): job = self.update_model(job.pk, status='pending') - # Start another task to process job events. - # if settings.BROKER_URL.startswith('amqp://'): - # app = Celery('tasks', broker=settings.BROKER_URL) - # send_task('awx.main.tasks.save_job_events', kwargs={ - # 'job_id': job.id, - # }, serializer='json') return True else: return False @@ -512,20 +506,6 @@ class RunJob(BaseTask): # to tell the save job events task to end. if settings.BROKER_URL.startswith('amqp://'): pass - # job_events_exchange = Exchange('job_events', 'direct', durable=True) - # job_events_queue = Queue('job_events[%d]' % job.id, - # exchange=job_events_exchange, - # routing_key=('job_events[%d]' % job.id), - # auto_delete=True) - # with Connection(settings.BROKER_URL, transport_options={'confirm_publish': True}) as conn: - # with conn.Producer(serializer='json') as producer: - # msg = { - # 'job_id': job.id, - # 'event': '__complete__' - # } - # producer.publish(msg, exchange=job_events_exchange, - # routing_key=('job_events[%d]' % job.id), - # declare=[job_events_queue]) # Update job event fields after job has completed (only when using REST # API callback). diff --git a/awx/main/tests/base.py b/awx/main/tests/base.py index be01c1c306..e4ad1b5ade 100644 --- a/awx/main/tests/base.py +++ b/awx/main/tests/base.py @@ -368,7 +368,7 @@ class BaseTestMixin(object): def start_queue(self, consumer_port, queue_port): self.queue_process = Process(target=run_subscriber, - args=(consumer_port, queue_port,)) + args=(consumer_port, queue_port, False,)) self.queue_process.start() def terminate_queue(self):