def get_event_buffer(self):
        d = self.event_buffer
        self.event_buffer = {}
        return d
Returns and flush the event buffer
dataset/ETHPy150Open airbnb/airflow/airflow/executors/base_executor.py/BaseExecutor.get_event_buffer