Skip to content

Commit

Permalink
[AIRFLOW-6950] Remove refresh_executor_config from ti.refresh_from_db (
Browse files Browse the repository at this point in the history
…#7577)

cherry-picked from 6a9b951
  • Loading branch information
kaxil committed Mar 17, 2020
1 parent c2f6cc1 commit 4edaccd
Showing 1 changed file with 1 addition and 6 deletions.
7 changes: 1 addition & 6 deletions airflow/models/taskinstance.py
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down Expand Up @@ -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

Expand Down

0 comments on commit 4edaccd

Please sign in to comment.