minor additions for compatibility with new cco.storage implementation
This commit is contained in:
		
							parent
							
								
									94ce64ef00
								
							
						
					
					
						commit
						a6fb663192
					
				
					 1 changed files with 4 additions and 0 deletions
				
			
		|  | @ -123,6 +123,7 @@ class TrackingStorage(BTreeContainer): | ||||||
|     runs = None             # currently active runs |     runs = None             # currently active runs | ||||||
|     finishedRuns = None     # finished runs |     finishedRuns = None     # finished runs | ||||||
|     currentRuns = None      # the currently active run for each task |     currentRuns = None      # the currently active run for each task | ||||||
|  |     storage = None          # compatibility with new cco.storage | ||||||
| 
 | 
 | ||||||
|     def __init__(self, *args, **kw): |     def __init__(self, *args, **kw): | ||||||
|         trackFactory = kw.pop('trackFactory', None) |         trackFactory = kw.pop('trackFactory', None) | ||||||
|  | @ -221,6 +222,9 @@ class TrackingStorage(BTreeContainer): | ||||||
|         self.indexTrack(trackNum, track) |         self.indexTrack(trackNum, track) | ||||||
|         return trackId |         return trackId | ||||||
| 
 | 
 | ||||||
|  |     def setTrackData(self, track, data): | ||||||
|  |         track.data = data   # persistent track: data will be stored automatically | ||||||
|  | 
 | ||||||
|     def updateTrack(self, track, data, overwrite=False): |     def updateTrack(self, track, data, overwrite=False): | ||||||
|         trackId = str(track.__name__) |         trackId = str(track.__name__) | ||||||
|         trackNum = int(trackId) |         trackNum = int(trackId) | ||||||
|  |  | ||||||
		Loading…
	
	Add table
		
		Reference in a new issue