Source Code for Module Ganga.GPIDev.Streamers.PickleStreamer

 1  ################################################################################ 
 2  # Ganga Project. http://cern.ch/ganga 
 3  # 
 4  # $Id: PickleStreamer.py,v 1.1 2008-07-17 16:40:56 moscicki Exp $ 
 5  ################################################################################ 
 6   
 7   
 8  from utilities import serialize, gangaObjectFactory 
 9  import pickle 
10   
11 -class PickleJobStreamer(object): 
12       
13 -    def getStreamFromJob(self, job): 
14          return pickle.dumps(serialize(job)) 
15   
16 -    def getJobFromStream(self, stream): 
17          return gangaObjectFactory(pickle.loads(stream)) 
18