'Sync the remote_info storage_policy_index if needed and return the
newly synced replication info.
:param broker: the database broker
:param remote_info: the remote replication info
:returns: local broker replication info'

def _get_synced_replication_info(self, broker, remote_info):

    info = broker.get_replication_info()
    if incorrect_policy_index(info, remote_info):
        status_changed_at = Timestamp.now().internal
        broker.set_storage_policy_index(remote_info['storage_policy_index'], timestamp=status_changed_at)
        info = broker.get_replication_info()
    return info
