Fixing bad rebase.

control/veda_heal.py

@@ -92,14 +92,15 @@ class VedaHeal(object):
             self.val_status = None
 
             # Enqueue
-            for e in encode_list:
-                veda_id = v.edx_id
-                encode_profile = e
-                jobid = uuid.uuid1().hex[0:10]
-                celeryapp.worker_task_fire.apply_async(
-                    (veda_id, encode_profile, jobid),
-                    queue=self.auth_dict['celery_worker_queue']
-                )
+            if self.auth_dict['rabbitmq_broker'] is not None:
+                for e in encode_list:
+                    veda_id = v.edx_id
+                    encode_profile = e
+                    jobid = uuid.uuid1().hex[0:10]
+                    celeryapp.worker_task_fire.apply_async(
+                        (veda_id, encode_profile, jobid),
+                        queue=self.auth_dict['celery_worker_queue']
+                    )
 
     def determine_fault(self, video_object):
         """

test_config.yaml

@@ -33,6 +33,9 @@ val_username: username
 val_transcript_create_url: http://val.edx.org/transcript/create
 val_video_transcript_status_url: http://val.edx.org/video/status
 
+celery_worker_queue: encode_worker
+celery_deliver_queue: deliver_worker
+
 # ----------
 ##---
 # This is a list of encodes and their respective course