Commit daaaf32f by Guba Sándor

adding celery decorators

parent 72d2eab3
#!/usr/bin/env python
import subprocess import subprocess
import logging import logging
from netcelery import celery
def ovs_command_execute(command): def ovs_command_execute(command):
'''Execute OpenVSwitch commands '''Execute OpenVSwitch commands
...@@ -24,11 +24,13 @@ def ofctl_command_execute(command): ...@@ -24,11 +24,13 @@ def ofctl_command_execute(command):
return return_val return return_val
@celery.task
def create(network_list): def create(network_list):
for network in network_list: for network in network_list:
port_create(network) port_create(network)
@celery.task
def delete(network_list): def delete(network_list):
for network in network_list: for network in network_list:
port_delete(network) port_delete(network)
......
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