def flush_bulk(self, forced=False):
        with self.bulk_lock:
            if forced or self.bulk_size >= len(self.bulk_data):
                batch = self.bulk_data
                self.bulk_data = []
            else:
                return None

        if len(batch) > 0:
            bulk_result = self.conn._send_request("POST",
                                                  "/_bulk",
                                                  "\n".join(batch) + "\n")

            if self.raise_on_bulk_item_failure:
                _raise_exception_if_bulk_item_failed(bulk_result)

            return bulk_result
dataset/ETHPy150Open aparo/pyes/pyes/models.py/ListBulker.flush_bulk/swapped operands of `>=`