edmIntegrityCheck.PublishToFileSystem Class Reference

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 17 of file edmIntegrityCheck.py.

Constructor & Destructor Documentation

__init__()

def edmIntegrityCheck.PublishToFileSystem.__init__	(		self,
			parent
	)

Definition at line 20 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 64 of file edmIntegrityCheck.py.

References edmIntegrityCheck.PublishToFileSystem.parent, confdb.HLTProcess.parent, FWPSetTableManager::PSetData.parent, emtf::Node.parent, EmDQMReco::FourVectorMonitorElements.parent, SlimmedCount.parent, options.HLTProcessOptions.parent, dqm::implementation::IBooker::UseScope< SCOPE >.parent, readConfig.fileINI.read(), SectorProcessorLUT.read(), cond::FileReader.read(), PtLUTReader.read(), l1ct::HadCaloObjEmu.read(), PtAssignmentEngine.read(), AlignmentCorrelationsIO.read(), FileBlob.read(), AlignmentCorrelationsIORoot.read(), pos::PixelROCTrimBits.read(), edm::RawInputSource.read(), pos::PixelROCMaskBits.read(), MultiFileBlob.read(), l1ct::EmCaloObjEmu.read(), FileReaderDCC.read(), FileReaderDDU.read(), LMap::impl.read(), AlignmentUserVariablesIO.read(), trklet::CircularBuffer< T >.read(), AlignmentParametersIO.read(), pos::PixelROCDACSettings.read(), SurveyPxbImageReader< T >.read(), personalPlayback.Applet.read(), ProduceDropBoxMetadata.read, l1ct::TkObjEmu.read(), RawFile.read(), trklet::TrackletEngineUnit.read(), l1t::LUT.read(), PedeReader.read(), trklet::MatchEngineUnit.read(), edmIntegrityCheck.PublishToFileSystem.read(), FedRawDataInputSource.read(), NuclearInteractionSimulator.read(), MixingInputConfig.read(), PyBind11ProcessDesc.read(), edmplugin::CacheParser.read(), l1ct::MuObjEmu.read(), DAQSource.read(), npstat::StorableMultivariateFunctor.read(), BuildTrackerMapPlugin.read(), CSCPairResidualsConstraint.read(), LMap.read(), l1ct::PFChargedObjEmu.read(), MillePedeFileReader.read(), npstat::UniformAxis.read(), MixingModuleConfig.read(), fastsim::NuclearInteraction.read(), l1ct::PFNeutralObjEmu.read(), npstat::StorableHistoNDFunctor< Numeric, Axis, Converter >.read(), edm::FileInPath.read(), npstat::DualAxis.read(), npstat::NUHistoAxis.read(), MuonResidualsTwoBin.read(), l1ct::PFRegionEmu.read(), npstat::GridAxis.read(), l1ct::PuppiObjEmu.read(), edm::streamer::StreamerInputSource.read(), npstat::HistoAxis.read(), npstat::DualHistoAxis.read(), l1ct::EGIsoObjEmu.read(), npstat::StorableInterpolationFunctor< Numeric, Axis, Converter >.read(), DQMTTreeIO::TreeReaderBase.read(), MuonResidualsFitter.read(), DQMTTreeIO::TreeObjectReader< T >.read(), l1ct::EGIsoEleObjEmu.read(), l1ct::PVObjEmu.read(), npstat::LinInterpolatedTableND< Numeric, Axis >.read(), DQMTTreeIO::TreeStringReader.read(), l1ct::RawInputs.read(), BitArray< N >.read(), DTTFBitArray< N >.read(), l1ct::RegionizerDecodedInputs.read(), DQMTTreeIO::TreeSimpleReader< T >.read(), l1ct::PFInputRegion.read(), l1ct::OutputRegion.read(), l1ct::OutputBoard.read(), l1ct::Event.read(), and npstat::HistoND< Numeric, Axis >.read().

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

    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])
                

publish()

def edmIntegrityCheck.PublishToFileSystem.publish	(		self,
			report
	)

Publish a file

Definition at line 26 of file edmIntegrityCheck.py.

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

    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)
                

read()

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

Reads a report from storage

Definition at line 55 of file edmIntegrityCheck.py.

References geometryDiff.file.

Referenced by edmIntegrityCheck.PublishToFileSystem.get().

    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)
    

Member Data Documentation

parent

edmIntegrityCheck.PublishToFileSystem.parent

Definition at line 22 of file edmIntegrityCheck.py.

Referenced by edmIntegrityCheck.PublishToFileSystem.get(), and edmIntegrityCheck.PublishToFileSystem.publish().