def _caches_to_update_affinity()

in pyignite/client.py [0:0]

• 5 lines of code
• 4 McCabe index (conditional complexity)

    def _caches_to_update_affinity(self):
        if self._affinity['version'] < self.affinity_version:
            return list(self._affinity['partition_mapping'].keys())
        else:
            return list(c_id for c_id, c_mapping in self._affinity['partition_mapping'].items() if not c_mapping)