Inheritance diagram for edmIntegrityCheck.PublishToFileSystem:

Public Member Functions
def	__init__ (self, parent)

def	get (self, dir)

def	publish (self, report)

def	read (self, lfn, local=False)

Public Attributes
	parent

Detailed Description

Write a report to storage

Definition at line 18 of file edmIntegrityCheck.py.

Constructor & Destructor Documentation

◆ init()

def edmIntegrityCheck.PublishToFileSystem.__init__	(	self,
		parent
	)

Definition at line 21 of file edmIntegrityCheck.py.

     def __init__(self, parent):
         if isinstance(parent, type("")):
             self.parent = parent
         else:
             self.parent = parent.__class__.__name__
     

Member Function Documentation

◆ get()

def edmIntegrityCheck.PublishToFileSystem.get	(	self,
		dir
	)

Finds the lastest file and reads it

Definition at line 65 of file edmIntegrityCheck.py.

     def get(self, dir):
         """Finds the lastest file and reads it"""
         reg = '^%s_.*\.txt$' % self.parent
         files = castortools.matchingFiles(dir, reg)
         files = sorted([ (os.path.basename(f), f) for f in files])
         if not files:
             return None
         return self.read(files[-1][1])
                 
  

References edmIntegrityCheck.PublishToFileSystem.parent, confdb.HLTProcess.parent, FWPSetTableManager::PSetData.parent, emtf::Node.parent, EmDQMReco::FourVectorMonitorElements.parent, options.HLTProcessOptions.parent, BeautifulSoup.PageElement.parent, globcontrol.parent, dqm::implementation::IBooker::UseScope< SCOPE >.parent, readConfig.fileINI.read(), cond::FileReader.read(), SectorProcessorLUT.read(), PtLUTReader.read(), FileBlob.read(), AlignmentCorrelationsIO.read(), PtAssignmentEngine.read(), pos::PixelROCTrimBits.read(), AlignmentCorrelationsIORoot.read(), edm::RawInputSource.read(), pos::PixelROCMaskBits.read(), MultiFileBlob.read(), SimBeamSpotObjects.read(), trklet::CircularBuffer< T >.read(), trklet::MatchEngineUnit.read(), LMap::impl.read(), AlignmentUserVariablesIO.read(), AlignmentParametersIO.read(), pos::PixelROCDACSettings.read(), SurveyPxbImageReader< T >.read(), personalPlayback.Applet.read(), bistream_iterator< T >.read(), PyBind11ProcessDesc.read(), RawFile.read(), PedeReader.read(), l1t::LUT.read(), cmspython3::PyBind11ProcessDesc.read(), FedRawDataInputSource.read(), edmIntegrityCheck.PublishToFileSystem.read(), NuclearInteractionSimulator.read(), edmplugin::CacheParser.read(), MixingInputConfig.read(), npstat::StorableMultivariateFunctor.read(), MillePedeFileReader.read(), BuildTrackerMapPlugin.read(), CSCPairResidualsConstraint.read(), LMap.read(), npstat::UniformAxis.read(), MixingModuleConfig.read(), fastsim::NuclearInteraction.read(), npstat::StorableHistoNDFunctor< Numeric, Axis, Converter >.read(), npstat::DualAxis.read(), npstat::NUHistoAxis.read(), edm::FileInPath.read(), MuonResidualsTwoBin.read(), edm::StreamerInputSource.read(), npstat::GridAxis.read(), npstat::HistoAxis.read(), npstat::DualHistoAxis.read(), npstat::StorableInterpolationFunctor< Numeric, Axis, Converter >.read(), DQMTTreeIO::TreeReaderBase.read(), MuonResidualsFitter.read(), DQMTTreeIO::TreeObjectReader< T >.read(), npstat::LinInterpolatedTableND< Numeric, Axis >.read(), DQMTTreeIO::TreeStringReader.read(), DTTFBitArray< N >.read(), BitArray< N >.read(), DQMTTreeIO::TreeSimpleReader< T >.read(), and npstat::HistoND< Numeric, Axis >.read().

Referenced by Options.Options.__getitem__(), betterConfigParser.BetterConfigParser.__updateDict(), betterConfigParser.BetterConfigParser.getCompares(), betterConfigParser.BetterConfigParser.getGeneral(), and betterConfigParser.BetterConfigParser.getResultingSection().

◆ publish()

def edmIntegrityCheck.PublishToFileSystem.publish	(	self,
		report
	)

Publish a file

Definition at line 27 of file edmIntegrityCheck.py.

     def publish(self, report):
         """Publish a file"""
         for path in report['PathList']:
             _, name = tempfile.mkstemp('.txt', text=True)
             json.dump(report, file(name,'w'), sort_keys=True, indent=4)
             
             fname = '%s_%s.txt' % (self.parent, report['DateCreated'])
             #rename the file locally - TODO: This is a potential problem
             nname = os.path.join(os.path.dirname(name),fname)
             os.rename(name, nname)
             
             castor_path = castortools.lfnToCastor(path)
             new_name = '%s/%s' % (castor_path, fname)
             castortools.xrdcp(nname,path)
             time.sleep(1)
             
             if castortools.fileExists(new_name):
                 
                 #castortools.move(old_name, new_name)
                 #castortools.chmod(new_name, '644')
  
                 print("File published: '%s'" % castortools.castorToLFN(new_name))
                 os.remove(nname)
             else:
                 pathhash = path.replace('/','.')
                 hashed_name = 'PublishToFileSystem-%s-%s' % (pathhash, fname)
                 shutil.move(nname, hashed_name)
                 print("Cannot write to directory '%s' - written to local file '%s' instead." % (castor_path, hashed_name), file=sys.stderr)
                 

References FrontierConditions_GlobalTag_cff.file, edmIntegrityCheck.PublishToFileSystem.parent, confdb.HLTProcess.parent, FWPSetTableManager::PSetData.parent, emtf::Node.parent, EmDQMReco::FourVectorMonitorElements.parent, options.HLTProcessOptions.parent, BeautifulSoup.PageElement.parent, globcontrol.parent, dqm::implementation::IBooker::UseScope< SCOPE >.parent, and edm.print().

◆ read()

def edmIntegrityCheck.PublishToFileSystem.read	(	self,
		lfn,
		local = `False`
	)

Reads a report from storage

Definition at line 56 of file edmIntegrityCheck.py.

     def read(self, lfn, local = False):
         """Reads a report from storage"""
         if local:
             cat = file(lfn).read()
         else:
             cat = castortools.cat(castortools.lfnToCastor(lfn))
         #print "the cat is: ", cat
         return json.loads(cat)
     