jakob/workdirfs
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

fix wrong filext, when list

Browse source
This commit is contained in:
Jakobus Schürz 2020-04-20 07:17:33 +02:00
parent 64776a8714
commit a297f48cc7
1 changed files with 4 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
workdirfs.py
View file

@ -156,7 +156,7 @@ class WorkdirFS(Operations):
if type(zipext) is str: if type(zipext) is str:
return zipext in filename return zipext in filename
elif type(zipext) is list: elif type(zipext) is list:
for e in arr: for e in zipext:
if (lambda x: x in filename)(e): if (lambda x: x in filename)(e):
return True return True
return False return False
@ -165,7 +165,8 @@ class WorkdirFS(Operations):
print("Cleanup dir", self.yesterdaypath) print("Cleanup dir", self.yesterdaypath)
#zip_fileext=".gz" #zip_fileext=".gz"
zip_fileext=[".gz","tgz",".gz.tar"] zip_fileexts=[".gz","tgz",".gz.tar"]
zip_fileext=".gz"
zip_compressionlevel=5 zip_compressionlevel=5
#for root, dirs, files in os.walk(self.yesterdaypath, topdown=False): #for root, dirs, files in os.walk(self.yesterdaypath, topdown=False):
print("Archivepath",self.archivpathbase) print("Archivepath",self.archivpathbase)
@ -180,7 +181,7 @@ class WorkdirFS(Operations):
for f in files: for f in files:
print("compress", os.path.join(root, f)) print("compress", os.path.join(root, f))
#if zip_fileext not in f: #if zip_fileext not in f:
if not _check_fileext(f,zip_fileext): if not self._check_fileext(f,zip_fileexts):
try: try:
with open(os.path.join(root, f), 'rb') as f_in: with open(os.path.join(root, f), 'rb') as f_in:
with gzip.open( with gzip.open(