diff --git a/airflow/models/taskinstance.py b/airflow/models/taskinstance.py index 5134f956d4a929..d43eab4989ab17 100644 --- a/airflow/models/taskinstance.py +++ b/airflow/models/taskinstance.py @@ -453,13 +453,10 @@ def error(self, session=None): session.commit() @provide_session - def refresh_from_db(self, session=None, lock_for_update=False, refresh_executor_config=False): + def refresh_from_db(self, session=None, lock_for_update=False): """ Refreshes the task instance from the database based on the primary key - :param refresh_executor_config: if True, revert executor config to - result from DB. Often, however, we will want to keep the newest - version :param lock_for_update: if True, indicates that the database should lock the TaskInstance (issuing a FOR UPDATE clause) until the session is committed. @@ -494,8 +491,6 @@ def refresh_from_db(self, session=None, lock_for_update=False, refresh_executor_ self.operator = ti.operator self.queued_dttm = ti.queued_dttm self.pid = ti.pid - if refresh_executor_config: - self.executor_config = ti.executor_config else: self.state = None