def _do_shard_change()

in datahub/client/common/shard_coordinator.py [0:0]

• 6 lines of code
• 7 McCabe index (conditional complexity)

    def _do_shard_change(self, add_shards, del_shards):
        if self._closed:
            self._logger.warning("ShardCoordinator closed when shard change. key: {}".format(self._uniq_key))
            raise DatahubException("ShardCoordinator closed when shard change")

        if self._shard_change and ((add_shards and len(add_shards) != 0) or (del_shards and len(del_shards) != 0)):
            self._shard_change(add_shards, del_shards)