diff --git a/airflow/models/taskinstance.py b/airflow/models/taskinstance.py index 863c0e4a2f62f..02bf4a7bd6f23 100644 --- a/airflow/models/taskinstance.py +++ b/airflow/models/taskinstance.py @@ -786,6 +786,11 @@ def refresh_from_task(self, task, pool_override=None): # value that needs to be stored in the db. self.executor_config = task.executor_config self.operator = task.task_type + # https://github.com/apache/airflow/discussions/21021 - not fully sure I understand this issue - specifically + # why only certain setups run into (found more instances on the Slack, but astronomer folk never hit it, which + # confuses me. Not sure if this effects Airflow 2.3, so not going to push this upstream yet, but let's keep this + # in mind. + self._log = logging.getLogger('airflow.task') @provide_session def clear_xcom_data(self, session=None):