diff --git a/airflow/models.py b/airflow/models.py index efe43eded4d..489a2a471e0 100755 --- a/airflow/models.py +++ b/airflow/models.py @@ -4406,8 +4406,6 @@ def get_state(self): def set_state(self, state): if self._state != state: self._state = state - self.end_date = timezone.utcnow() if self._state in State.finished() else None - if self.dag_id is not None: # something really weird goes on here: if you try to close the session # dag runs will end up detached