def METHOD_NAME(self, items=10):
    """Test whether fetched items are properly loaded to ES"""
    items_count = 0
    identities_count = 0
    start = datetime.datetime.now().timestamp()
    new_identities = []
    for i in range(items):
        items_count += 1
        identities = create_fake_identities()
        for identity in identities:
            if identity not in new_identities:
                new_identities.append(identity)
        if items_count % 500 == 0:
            inserted_identities = self.load_bulk_identities(items_count,
                                                            new_identities,
                                                            self.enrich_backend.sh_db,
                                                            self.enrich_backend.get_connector_name())
            identities_count += inserted_identities
            new_identities = []
    if new_identities:
        inserted_identities = self.load_bulk_identities(items_count,
                                                        new_identities,
                                                        self.enrich_backend.sh_db,
                                                        self.enrich_backend.get_connector_name())
        identities_count += inserted_identities
    stop = datetime.datetime.now().timestamp()
    self.assertLess((stop - start), 40.0)