sanghee/dynamicweb
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Updated cdist integration code with index parameter

Browse source
This commit is contained in:
PCoder 2017-08-31 12:55:19 +05:30
commit b35e74e355
1 changed files with 10 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

15
utils/tasks.py
View file

@ -1,6 +1,7 @@
import cdist
import tempfile import tempfile
from cdist.integration import configure_hosts_simple
import cdist
import cdist.integration as cdist_integration
from celery.utils.log import get_task_logger from celery.utils.log import get_task_logger
from django.conf import settings from django.conf import settings
from django.core.mail import EmailMessage from django.core.mail import EmailMessage
@ -50,9 +51,13 @@ def save_ssh_key(self, hosts, keys):
tmp_manifest.writelines(lines_list) tmp_manifest.writelines(lines_list)
tmp_manifest.flush() tmp_manifest.flush()
try: try:
configure_hosts_simple(hosts, cdist_instance_index = cdist_integration.instance_index
tmp_manifest.name, cdist_index = next(cdist_instance_index)
verbose=cdist.argparse.VERBOSE_TRACE) cdist_integration.configure_hosts_simple(hosts,
tmp_manifest.name,
index=cdist_index,
verbose=cdist.argparse.VERBOSE_TRACE)
cdist_instance_index.free(cdist_index)
except Exception as cdist_exception: except Exception as cdist_exception:
logger.error(cdist_exception) logger.error(cdist_exception)
return_value = False return_value = False