'Create a bulker object and return it to allow to manage custom bulk policies'

def create_bulker(self):

    return self.bulker_class(self, bulk_size=self.bulk_size, raise_on_bulk_item_failure=self.raise_on_bulk_item_failure)
