Skip to content

Commit

Permalink
adjust refresh
Browse files Browse the repository at this point in the history
  • Loading branch information
jx2lee committed Feb 4, 2025
1 parent 6aefcf4 commit d5ddaf3
Showing 1 changed file with 5 additions and 2 deletions.
7 changes: 5 additions & 2 deletions airflow/dag_processing/bundles/git.py
Original file line number Diff line number Diff line change
Expand Up @@ -262,8 +262,11 @@ def _fetch_bare_repo(self):
def refresh(self) -> None:
if self.version:
raise AirflowException("Refreshing a specific version is not supported")
self._fetch_bare_repo()
self.repo.remotes.origin.pull()

with self.hook.setup_inline_key() as tmp_keyfile:
self.hook.env = self.hook.set_git_env(tmp_keyfile)
self._fetch_bare_repo()
self.repo.remotes.origin.pull()

@staticmethod
def _convert_git_ssh_url_to_https(url: str) -> str:
Expand Down

0 comments on commit d5ddaf3

Please sign in to comment.