'Respond to executor events.
:param executor: the executor that\'s running the task instances
:type executor: BaseExecutor
:return: None'

def _process_executor_events(self):

    for (key, executor_state) in list(self.executor.get_event_buffer().items()):
        (dag_id, task_id, execution_date) = key
        self.logger.info(u'Executor    reports    {}.{}    execution_date={}    as    {}'.format(dag_id, task_id, execution_date, executor_state))
