Skip to content

CIRCLE / agentdriver

Go to a project
Commit 7ef51fca by Bach Dániel
Options

add update task

parent 10436dd9
Showing with 7 additions and 0 deletions
agentcelery.py
...@@ -73,6 +73,13 @@ def start_access_server(vm): ...@@ -73,6 +73,13 @@ def start_access_server(vm):
logger.debug('start_access_server(%s)' % vm) logger.debug('start_access_server(%s)' % vm)
@celery.task(name='agent.update')
def update(vm):
reactor.connections[vm].send_command(
command='update', args={})
logger.debug('update(%s)' % vm)
@celery.task(name='vm.tasks.local_agent_tasks.agent_started') @celery.task(name='vm.tasks.local_agent_tasks.agent_started')
def agent_started(vm): def agent_started(vm):
print 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