@provide_session
    def clear_xcom_data(self, session=None):
        session.query(XCom).filter(
            XCom.dag_id == self.dag_id,
            XCom.task_id == self.task_id,
            XCom.execution_date == self.execution_date
        ).delete()
        session.commit()
Test that events are dispatched to listeners
dataset/ETHPy150Open airbnb/airflow/airflow/models.py/TaskInstance.clear_xcom_data--crossover with--dataset/ETHPy150Open tuturto/pyherc/src/pyherc/test/unit/test_model.py/TestModel.test_dispatching_event_to_listeners