@provide_session<EOL><INDENT>def clear_xcom_data(self, session=None):<DEDENT>
session.query(XCom).filter(<EOL>XCom.dag_id == self.dag_id,<EOL>XCom.task_id == self.task_id,<EOL>XCom.execution_date == self.execution_date<EOL>).delete()<EOL>session.commit()<EOL>
Clears all XCom data from the database for the task instance