Commit 690f8f52 by Guba Sándor

refactor

parent 406a7949
...@@ -61,6 +61,7 @@ def connect(connection_string='qemu:///system'): ...@@ -61,6 +61,7 @@ def connect(connection_string='qemu:///system'):
logging.debug("There is already an active connection to libvirt.") logging.debug("There is already an active connection to libvirt.")
else: else:
connection = lib_connection connection = lib_connection
logging.debug("Using celery libvirt connection connection.")
@celery.task @celery.task
def disconnect(): def disconnect():
......
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