

def _get_synced_replication_info(self, broker, remote_info):
    '\n        Sync the remote_info storage_policy_index if needed and return the\n        newly synced replication info.\n\n        :param broker: the database broker\n        :param remote_info: the remote replication info\n\n        :returns: local broker replication info\n        '
    info = broker.get_replication_info()
    if incorrect_policy_index(info, remote_info):
        status_changed_at = Timestamp(time.time()).internal
        broker.set_storage_policy_index(remote_info['storage_policy_index'], timestamp=status_changed_at)
        info = broker.get_replication_info()
    return info

dataset/ETHPy150Open openstack/swift/swift/container/replicator.py ContainerReplicatorRpc._get_synced_replication_info/original