mirror of
https://github.com/saltstack/salt.git
synced 2025-04-17 10:10:20 +00:00
Accept and pass through the alternate cachedir when prepping the thin tar
This commit is contained in:
parent
c3f7a2f2e5
commit
65bdcb3afa
1 changed files with 4 additions and 3 deletions
|
@ -119,7 +119,7 @@ def salt_refs(data, ret=None):
|
|||
return ret
|
||||
|
||||
|
||||
def prep_trans_tar(file_client, chunks, file_refs, pillar=None):
|
||||
def prep_trans_tar(file_client, chunks, file_refs, pillar=None, id_=None):
|
||||
'''
|
||||
Generate the execution package from the saltenv file refs and a low state
|
||||
data structure
|
||||
|
@ -142,6 +142,7 @@ def prep_trans_tar(file_client, chunks, file_refs, pillar=None):
|
|||
if pillar:
|
||||
with salt.utils.fopen(pillarfn, 'w+') as fp_:
|
||||
fp_.write(json.dumps(pillar))
|
||||
cachedir = os.path.join('salt-ssh', id_)
|
||||
for saltenv in file_refs:
|
||||
file_refs[saltenv].extend(sync_refs)
|
||||
env_root = os.path.join(gendir, saltenv)
|
||||
|
@ -150,7 +151,7 @@ def prep_trans_tar(file_client, chunks, file_refs, pillar=None):
|
|||
for ref in file_refs[saltenv]:
|
||||
for name in ref:
|
||||
short = name[7:]
|
||||
path = file_client.cache_file(name, saltenv)
|
||||
path = file_client.cache_file(name, saltenv, cachedir=cachedir)
|
||||
if path:
|
||||
tgt = os.path.join(env_root, short)
|
||||
tgt_dir = os.path.dirname(tgt)
|
||||
|
@ -158,7 +159,7 @@ def prep_trans_tar(file_client, chunks, file_refs, pillar=None):
|
|||
os.makedirs(tgt_dir)
|
||||
shutil.copy(path, tgt)
|
||||
continue
|
||||
files = file_client.cache_dir(name, saltenv)
|
||||
files = file_client.cache_dir(name, saltenv, cachedir=cachedir)
|
||||
if files:
|
||||
for filename in files:
|
||||
fn = filename[filename.find(short) + len(short):]
|
||||
|
|
Loading…
Add table
Reference in a new issue