Skip to content

Commit

Permalink
Re #7987. Making the chunking workspace far more temporary.
Browse files Browse the repository at this point in the history
  • Loading branch information
peterfpeterson committed Feb 5, 2014
1 parent a9ce6ce commit 8aea996
Showing 1 changed file with 8 additions and 8 deletions.
Expand Up @@ -593,15 +593,17 @@ def _getStrategy(self, runnumber, extension):
wksp = "%s_%d" % (self._instrument, runnumber)
strategy = []
self.log().debug("[Fx116] Run file Name : %s,\t\tMax chunk size: %s" % (str(wksp+extension), str(self._chunks)))
if True:
Chunks = api.DetermineChunking(Filename=wksp+extension,MaxChunkSize=self._chunks)
else:
api.DetermineChunking(Filename=wksp+extension,MaxChunkSize=self._chunks,OutputWorkspace='Chunks')
Chunks = AnalysisDataService.retrieve("Chunks")
for row in Chunks: strategy.append(row)
chunks = api.DetermineChunking(Filename=wksp+extension,MaxChunkSize=self._chunks)
for row in chunks:
strategy.append(row)
#For table with no rows
if not strategy:
strategy.append({})

# delete chunks workspace
chunks = str(chunks)
mtd.remove(chunks)

return strategy

def _focusChunks(self, runnumber, extension, filterWall, calib, splitwksp=None, preserveEvents=True,
Expand Down Expand Up @@ -795,8 +797,6 @@ def _focusChunks(self, runnumber, extension, filterWall, calib, splitwksp=None,
for itemp in xrange(numwksp):
wksplist[itemp].getRun()['iparm_file'] = self._config.iparmFile

api.DeleteWorkspace('Chunks')

for itemp in xrange(numwksp):
#if wksplist[itemp].__class__.__name__.count("Event") > 0:
# try:
Expand Down

0 comments on commit 8aea996

Please sign in to comment.