fixes trying to change properties in sStreamToFileTool

graphics/EventDisplaysOnline/python/EventDisplaysOnlineConfig.py

@@ -3,7 +3,7 @@
 from AthenaConfiguration.ComponentAccumulator import ComponentAccumulator
 from AthenaConfiguration.ComponentFactory import CompFactory
 from EventDisplaysOnline.EventDisplaysOnlineHelpers import GetRunType, GetBFields, WaitForPartition
-from AthenaCommon.Constants import INFO, DEBUG, ERROR, WARNING
+from AthenaCommon.Constants import INFO, DEBUG
 
 isHIMode = False #TODO
 #TODO isBeamSplashMode = False
@@ -108,6 +108,7 @@ if partitionName == 'ATLAS' and not testWithoutPartition and not isOfflineTest:
     from ispy import ISObject, IPCPartition
     RunParams = ISObject(IPCPartition(partitionName), 'RunParams.RunParams', 'RunParams')
     RunParams.checkout()
+    flags.Input.OverrideRunNumber = True
     flags.Input.RunNumbers = [RunParams.run_number]
     
     # Get the B field
@@ -118,7 +119,8 @@ if partitionName == 'ATLAS' and not testWithoutPartition and not isOfflineTest:
     flags.BField.endcapToroidOn = toroidOn
 
 # GM test partition needs to be given the below info
-if (partitionName == 'GMTestPartition' or partitionName == 'GMTestPartitionT9') or testWithoutPartition:# or isOfflineTest:
+if (partitionName == 'GMTestPartition' or partitionName == 'GMTestPartitionT9') or testWithoutPartition:
+    flags.Input.OverrideRunNumber = True
     flags.Input.RunNumbers = [412343]
     flags.Input.LumiBlockNumbers = [1]
     flags.Input.ProjectName = projectName
@@ -184,7 +186,7 @@ def StreamToFileToolCfg(flags,**kwargs):
     the_tool = CompFactory.JiveXML.StreamToFileTool(**kwargs)
     result.setPrivateTools(the_tool)
     return result
-acc.popToolsAndMerge(StreamToFileToolCfg(flags))
+streamToFileTool = acc.popToolsAndMerge(StreamToFileToolCfg(flags))
 
 if not isOfflineTest:
     def StreamToServerToolCfg(flags, name="StreamToServerTool",**kwargs):
@@ -202,15 +204,16 @@ from JiveXML.JiveXMLConfig import AlgoJiveXMLCfg
 acc.merge(AlgoJiveXMLCfg(flags))
 
 from EventDisplaysOnline.OnlineEventDisplaysSvc import OnlineEventDisplaysSvc
-acc.addService(OnlineEventDisplaysSvc(
+svc = OnlineEventDisplaysSvc(
     name = "OnlineEventDisplaysSvc",
     OutputLevel = DEBUG,               # Verbosity
     MaxEvents = maxEvents,             # Number of events to keep per stream
     OutputDirectory = outputDirectory, # Base directory for streams
     ProjectTags = projectTags,         # Project tags that are allowed to be made public
     Public = publicStreams,            # These streams go into public stream when Ready4Physics
-
-), create=True)
+    StreamToFileTool = streamToFileTool,
+)
+acc.addService(svc, create=True)
 
 # This creates an ESD file per event which is renamed and moved to the desired output
 # dir in the VP1 Event Prod alg

graphics/EventDisplaysOnline/python/OnlineEventDisplaysSvc.py

@@ -10,7 +10,7 @@ __author__  = "Eric Jansen <eric.jansen@cern.ch>"
 
 import os, grp, stat, random
 from ipc import IPCPartition
-from ispy import ISInfoDictionary, ISInfoAny, ISObject
+from ispy import ISInfoDictionary
 from AthenaPython import PyAthena
 from AthenaPython.PyAthena import StatusCode
 from PyAnalysisCore import PyEventTools
@@ -28,7 +28,7 @@ class OnlineEventDisplaysSvc( PyAthena.Svc ):
                 self.zpgid = None
                 self.partition = None
 
-                self.StreamToFileTool = None
+                self.StreamToFileTool = kw.get('StreamToFileTool')
                 self.StreamToServerTool = None
                 self.VP1EventProducer = None
                 
@@ -46,7 +46,13 @@ class OnlineEventDisplaysSvc( PyAthena.Svc ):
 
                 self.partition = IPCPartition('ATLAS')
                 self.dict = ISInfoDictionary(self.partition)
-                self.zpgid = grp.getgrnam("zp").gr_gid
+                try:
+                        self.zpgid = grp.getgrnam("zp").gr_gid
+                except:
+                        # If running on private machine, zp group might not exist. 
+                        # Just set to the likely value
+                        self.zpgid = 1307 
+
                 return StatusCode.Success
 
         def finalize(self):