Commit d9da5065 authored by Michael Hanselmann's avatar Michael Hanselmann
Browse files

rpc: Call result processor once for each node result



… instead of calling it with the whole results dictionary. This
fixes an issue when replacing disks (and all other cases where
result processors are used).
Signed-off-by: default avatarMichael Hanselmann <hansmi@google.com>
Reviewed-by: default avatarIustin Pop <iustin@google.com>
parent cc19798f
......@@ -448,7 +448,8 @@ class _RpcClientBase:
result = self._proc(node_list, procedure, body, read_timeout=read_timeout)
if postproc_fn:
return postproc_fn(result)
return dict(map(lambda (key, value): (key, postproc_fn(value)),
result.items()))
else:
return result
......
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 to comment