ViewVC Help

View File | Revision Log | Show Annotations | Root Listing

root/cvsroot/COMP/CRAB/python/Publisher.py

Comparing COMP/CRAB/python/Publisher.py (file contents):
Revision 1.35 by fanzago, Tue Jun 16 17:07:14 2009 UTC vs.
Revision 1.37 by fanzago, Wed Jun 24 16:46:25 2009 UTC

#	Line 75 | Line 75 | class Publisher(Actor):
75		self.dataset_to_import.append(dataset)
76		###
77
78	+	self.import_all_parents = cfg_params.get('USER.publish_with_import_all_parents',0)
79		self.skipOcheck=cfg_params.get('CMSSW.publish_zero_event',0)
80
81		self.SEName=''
#	Line 88 | Line 89 | class Publisher(Actor):
89		def importParentDataset(self,globalDBS, datasetpath):
90		"""
91		"""
91	–	print " patch for importParentDataset: datasetpath = ", datasetpath
92	–	"""
92		dbsWriter = DBSWriter(self.DBSURL,level='ERROR')
93
94		try:
95	<	#dbsWriter.importDatasetWithoutParentage(globalDBS, datasetpath, self.DBSURL)
96	<	dbsWriter.importDataset(globalDBS, datasetpath, self.DBSURL)
95	>	if (self.import_all_parents=='1'):
96	>	common.logger.info("--->>> Importing all parents level")
97	>	dbsWriter.importDataset(globalDBS, datasetpath, self.DBSURL)
98	>	else:
99	>	common.logger.info("--->>> Importing only the datasetpath " + datasetpath)
100	>	dbsWriter.importDatasetWithoutParentage(globalDBS, datasetpath, self.DBSURL)
101		except DBSWriterError, ex:
102		msg = "Error importing dataset to be processed into local DBS\n"
103		msg += "Source Dataset: %s\n" % datasetpath
#	Line 105 | Line 108 | class Publisher(Actor):
108		return 1
109		return 0
110		"""
111	+	print " patch for importParentDataset: datasetpath = ", datasetpath
112		try:
113		args={}
114		args['url']=self.DBSURL
#	Line 121 | Line 125 | class Publisher(Actor):
125		return 1
126		print "Done"
127		return 0
128	<
128	>	"""
129		def publishDataset(self,file):
130		"""
131		"""

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines
>	Changed lines