Commit 492a0407 by Bach Dániel

vm: rename agent.start_ssh celery task

parent c47d3949
...@@ -48,6 +48,6 @@ def cleanup(vm): ...@@ -48,6 +48,6 @@ def cleanup(vm):
pass pass
@celery.task(name='agent.start_ssh') @celery.task(name='agent.start_access_server')
def start_ssh(vm): def start_access_server(vm):
pass pass
...@@ -17,7 +17,7 @@ ...@@ -17,7 +17,7 @@
from manager.mancelery import celery from manager.mancelery import celery
from vm.tasks.agent_tasks import (restart_networking, change_password, from vm.tasks.agent_tasks import (restart_networking, change_password,
set_time, set_hostname, start_ssh, set_time, set_hostname, start_access_server,
cleanup) cleanup)
import time import time
...@@ -50,9 +50,9 @@ def agent_started(vm): ...@@ -50,9 +50,9 @@ def agent_started(vm):
pass pass
if not initialized: if not initialized:
send_init_commands(instance, act, vm) send_init_commands(instance, act, vm)
with act.sub_activity('start_ssh'): with act.sub_activity('start_access_server'):
queue = instance.get_remote_queue_name("agent") queue = instance.get_remote_queue_name("agent")
start_ssh.apply_async( start_access_server.apply_async(
queue=queue, args=(vm, )) queue=queue, args=(vm, ))
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment