Commit 10436dd9 by Bach Dániel

add new tasks

parent d6a0ff91
......@@ -60,6 +60,19 @@ def mount_store(vm, host, username, password):
logger.debug('mount_store(%s,%s,%s)' % (vm, host, username))
@celery.task(name='agent.cleanup')
def cleanup(vm):
reactor.connections[vm].send_command(command='cleanup', args={})
logger.debug('cleanup(%s)' % vm)
@celery.task(name='agent.start_access_server')
def start_access_server(vm):
reactor.connections[vm].send_command(
command='start_access_server', args={})
logger.debug('start_access_server(%s)' % vm)
@celery.task(name='vm.tasks.local_agent_tasks.agent_started')
def agent_started(vm):
print 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