CMS 3D CMS Logo
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Pages
List of all members | Public Member Functions
production_tasks.GZipFiles Class Reference
Inheritance diagram for production_tasks.GZipFiles:
production_tasks.Task

Public Member Functions

def __init__
 
def gzip
 
def run
 
- Public Member Functions inherited from production_tasks.Task
def __init__
 
def addOption
 
def getname
 
def run
 

Additional Inherited Members

- Public Attributes inherited from production_tasks.Task
 dataset
 
 instance
 
 name
 
 options
 
 user
 

Detailed Description

GZip a list of files

Definition at line 165 of file production_tasks.py.

Constructor & Destructor Documentation

def production_tasks.GZipFiles.__init__ (   self,
  dataset,
  user,
  options 
)

Definition at line 167 of file production_tasks.py.

167 
168  def __init__(self, dataset, user, options):
Task.__init__(self,'GZipFiles', dataset, user, options)
production_tasks.GZipFiles.__init__
def __init__
Definition: production_tasks.py:167

Member Function Documentation

def production_tasks.GZipFiles.gzip (   self,
  fileName 
)

Definition at line 169 of file production_tasks.py.

Referenced by production_tasks.GZipFiles.run().

169 
170  def gzip(self, fileName):
171  output = '%s.gz' % fileName
172 
173  f_in = open(fileName, 'rb')
174  f_out = gzip.open(output, 'wb')
175  f_out.writelines(f_in)
176  f_out.close()
177  f_in.close()
178  #remove the original file once we've gzipped it
179  os.remove(fileName)
180  return output
production_tasks.GZipFiles.gzip
def gzip
Definition: production_tasks.py:169
def production_tasks.GZipFiles.run (   self,
  input 
)

Definition at line 181 of file production_tasks.py.

References production_tasks.GZipFiles.gzip().

181 
182  def run(self, input):
183  files = input['FilesToCompress']['Files']
184 
185  compressed = []
186  for f in files:
187  if f is None or not f: continue
188  if os.path.exists(f):
189  gz = self.gzip(f)
190  compressed.append(gz)
return {'CompressedFiles':compressed}
production_tasks.GZipFiles.gzip
def gzip
Definition: production_tasks.py:169
production_tasks.GZipFiles.run
def run
Definition: production_tasks.py:181
Generated for CMSSW Reference Manual by doxygen 1.8.5