def _take_snapshots(self):
data = {}<EOL>d = defer.gatherResults([<EOL>node.take_snapshot().addCallback(<EOL>lambda res: data.update(res['<STR_LIT:message>'])) for node in self.nodes<EOL>])<EOL>d.addCallback(lambda _: data)<EOL>return d<EOL>
Take snapshots of all nodes