Move install diagnostics task from vm driver to agent driver.

circle/vm/operations.py

@@ -464,8 +464,8 @@ class DeployOperation(InstanceOperation):
         name = _("Start diagnostics on virtual machine")
         name = _("Start diagnostics on virtual machine")
 
 
         def _operation(self):
         def _operation(self):
-            vm_tasks.install_diagnostics_extension.apply_async(
-                args=[self.instance.name], queue="localhost.vm.fast"
+            agent_tasks.install_diagnostics_extension.apply_async(
+                args=[self.instance.name], queue="localhost.localdomain.agent"
             ).get(timeout=1200)
             ).get(timeout=1200)
 
 
 @register_operation
 @register_operation

circle/vm/tasks/agent_tasks.py

@@ -17,6 +17,9 @@
 
 
 from manager.mancelery import celery
 from manager.mancelery import celery
 
 
+@celery.task(name='agent.install_diagnostics_extension')
+def install_diagnostics_extension(vm_name):
+    pass
 
 
 @celery.task(name='agent.change_password')
 @celery.task(name='agent.change_password')
 def change_password(vm, password):
 def change_password(vm, password):

circle/vm/tasks/vm_tasks.py

@@ -61,10 +61,6 @@ def get_queues():
         cache.set(key, result, 10)
         cache.set(key, result, 10)
     return result
     return result
 
 
-@celery.task(name='vmdriver.install_diagnostics_extension')
-def install_diagnostics_extension(vm_name):
-    pass
-
 @celery.task(name='vmdriver.save_as_template')
 @celery.task(name='vmdriver.save_as_template')
 def save_as_template(vm_name, vm_pk):
 def save_as_template(vm_name, vm_pk):
     pass
     pass