def send_buffered_operations(self):
with self.lock:<EOL><INDENT>try:<EOL><INDENT>action_buffer = self.BulkBuffer.get_buffer()<EOL>if action_buffer:<EOL><INDENT>successes, errors = bulk(self.elastic, action_buffer)<EOL>LOG.debug(<EOL>"<STR_LIT>" "<STR_LIT>",<EOL>successes,<EOL>)<EOL>if errors:<EOL><INDENT>LOG.error("<STR_LIT>", errors)<EOL><DEDENT><DEDENT><DEDENT>except es_exceptions.ElasticsearchException:<EOL><INDENT>LOG.exception("<STR_LIT>")<EOL><DEDENT><DEDENT>
Send buffered operations to Elasticsearch.

        This method is periodically called by the AutoCommitThread.