saltstack/salt
1
0
Fork 0
mirror of https://github.com/saltstack/salt.git synced 2025-04-16 09:40:20 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

Fix tech-debt for Git Pillar data with os.walk

Browse source
This commit is contained in:
David Murphy 2025-02-10 16:18:56 -07:00 • committed by Daniel Wozniak
parent 4725d274dc
commit 2dbbcb5ed1
1 changed files with 69 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

69
salt/utils/gitfs.py
View file

@ -2798,8 +2798,77 @@ class GitBase:
name = getattr(repo, "name", None)
if not remotes or (repo.id, name) in remotes or name in remotes:
try:
## DGM # Find and place fetch_request file for all the other branches for this repo
## DGM repo_work_hash = os.path.split(repo.get_salt_working_dir())[0]
## DGM for branch in os.listdir(repo_work_hash):
## DGM # Don't place fetch request in current branch being updated
## DGM if branch == repo.get_cache_basename():
## DGM continue
## DGM branch_salt_dir = salt.utils.path.join(repo_work_hash, branch)
## DGM fetch_path = salt.utils.path.join(
## DGM branch_salt_dir, "fetch_request"
## DGM )
## DGM if os.path.isdir(branch_salt_dir):
## DGM try:
## DGM with salt.utils.files.fopen(fetch_path, "w"):
## DGM pass
## DGM except OSError as exc: # pylint: disable=broad-except
## DGM log.error(
## DGM "Failed to make fetch request: %s %s",
## DGM fetch_path,
## DGM exc,
## DGM exc_info=True,
## DGM )
## DGM else:
## DGM log.error("Failed to make fetch request: %s", fetch_path)
# Find and place fetch_request file for all the other branches for this repo
repo_work_hash = os.path.split(repo.get_salt_working_dir())[0]
print(
f"DGM class GitBase fetch_remotes, repo_work_hash '{repo_work_hash}', salt working dir '{repo.get_salt_working_dir()}'",
flush=True,
)
branches = [
os.path.relpath(path, repo_work_hash)
for (path, subdirs, files) in os.walk(repo_work_hash)
if not subdirs
]
print(
f"DGM class GitBase fetch_remotes, branches '{branches}' from repo_work_hash '{repo_work_hash}'",
flush=True,
)
## DGM for branch in os.listdir(repo_work_hash):
for branch in os.listdir(branches):
# Don't place fetch request in current branch being updated
print(
f"DGM class GitBase fetch_remotes, for loop branch, branch '{branch}', repo get_cache_basename '{repo.get_cache_basename()}'",
flush=True,
)
if branch == repo.get_cache_basename():
continue
branch_salt_dir = salt.utils.path.join(repo_work_hash, branch)
fetch_path = salt.utils.path.join(
branch_salt_dir, "fetch_request"
)
print(
f"DGM class GitBase fetch_remotes, for loop branch, branch_salt_dir '{branch_salt_dir}', fetch_path '{fetch_path}'",
flush=True,
)
if os.path.isdir(branch_salt_dir):
try:
with salt.utils.files.fopen(fetch_path, "w"):
pass
except OSError as exc: # pylint: disable=broad-except
log.error(
"Failed to make fetch request: %s %s",
fetch_path,
exc,
exc_info=True,
)
else:
log.error("Failed to make fetch request: %s", fetch_path)
for branch in os.listdir(repo_work_hash):
# Don't place fetch request in current branch being updated
if branch == repo.get_cache_basename():