removed dict comprehension as 2.6 does not like
This commit is contained in:
parent
032690a843
commit
4203b699a8
2 changed files with 7 additions and 2 deletions
|
@ -108,7 +108,9 @@ class ResultProcess(multiprocessing.Process):
|
|||
|
||||
# if this task is registering a result, do it now
|
||||
if result._task.register:
|
||||
res = {k: result._result[k] for k in set(result._result.keys()).difference(C.RESULT_SANITIZE)}
|
||||
res = {}
|
||||
for k in set(result._result.keys()).difference(C.RESULT_SANITIZE):
|
||||
res[k] = result._result[k]
|
||||
self._send_result(('register_host_var', result._host, result._task.register, res))
|
||||
|
||||
# send callbacks, execute other options based on the result status
|
||||
|
|
|
@ -53,7 +53,10 @@ class CallbackBase:
|
|||
return json.dumps(res, indent=indent, ensure_ascii=False, sort_keys=sort_keys)
|
||||
|
||||
def _sanitize_result(self, result):
|
||||
return {k: result[k] for k in set(result.keys()).difference(C.RESULT_SANITIZE)}
|
||||
res = {}
|
||||
for k in set(result.keys()).difference(C.RESULT_SANITIZE):
|
||||
res[k] = result[k]
|
||||
return res
|
||||
|
||||
def set_connection_info(self, conn_info):
|
||||
pass
|
||||
|
|
Loading…
Reference in a new issue