def get_buffer(self):
<EOL>if self.doc_to_update:<EOL><INDENT>self.update_sources()<EOL><DEDENT>ES_buffer = self.action_buffer<EOL>self.clean_up()<EOL>return ES_buffer<EOL>
Get buffer which needs to be bulked to elasticsearch