code: def run(self):
          
          return elasticsearch.helpers.bulk(
              self.client,
              self.actionsiter(),
              stats_only=True,
              chunk_size=50
          )
docs: Process events queue.