Mercurial > piecrust2

comparison piecrust/baking/worker.py @ 1019:bd544b65cfad

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
bake: More detailed stats, and fix a problem with some error reporting.
author Ludovic Chabant <ludovic@chabant.com>
date Wed, 29 Nov 2017 21:36:11 -0800
parents fa489c5e829e
children
comparison
equal deleted inserted replaced
1018:3c6e6e7b9639 1019:bd544b65cfad
41 app.config.set('site/asset_url_format', '%page_uri%/%filename%') 41 app.config.set('site/asset_url_format', '%page_uri%/%filename%')
42 42
43 app.env.fs_cache_only_for_main_page = True 43 app.env.fs_cache_only_for_main_page = True
44 44
45 stats = app.env.stats 45 stats = app.env.stats
46 stats.registerTimer("BakeWorker_%d_Total" % self.wid) 46 stats.registerTimer("Worker_%d_Total" % self.wid)
47 stats.registerTimer("BakeWorkerInit") 47 stats.registerTimer("Worker_%d_Init" % self.wid)
48 48
49 self.app = app 49 self.app = app
50 self.stats = stats 50 self.stats = stats
51 51
52 # Load previous record 52 # Load previous record
72 self.ppmngr.createPipeline(src) 72 self.ppmngr.createPipeline(src)
73 73
74 stats.registerTimer("PipelineJobs_%s" % pname, 74 stats.registerTimer("PipelineJobs_%s" % pname,
75 raise_if_registered=False) 75 raise_if_registered=False)
76 76
77 stats.stepTimerSince("BakeWorkerInit", self._work_start_time) 77 stats.stepTimerSince(
78 "Worker_%d_Init" % self.wid, self._work_start_time)
78 79
79 def process(self, job): 80 def process(self, job):
80 source_name, item_spec = job['job_spec'] 81 source_name, item_spec = job['job_spec']
81 logger.debug("Received job: %s@%s" % (source_name, item_spec)) 82 logger.debug("Received job: %s@%s" % (source_name, item_spec))
82 83
96 97
97 return ppres 98 return ppres
98 99
99 def getStats(self): 100 def getStats(self):
100 stats = self.app.env.stats 101 stats = self.app.env.stats
101 stats.stepTimerSince("BakeWorker_%d_Total" % self.wid, 102 stats.stepTimerSince("Worker_%d_Total" % self.wid,
102 self._work_start_time) 103 self._work_start_time)
103 return stats 104 return stats
104 105
105 def shutdown(self): 106 def shutdown(self):
106 for src, pp in self._sources.values(): 107 for src, pp in self._sources.values():