Mercurial > piecrust2
comparison piecrust/serving/procloop.py @ 876:d1095774bfcf
refactor: Fix some issues with record/cache entry collisions, add counters.
author | Ludovic Chabant <ludovic@chabant.com> |
---|---|
date | Thu, 15 Jun 2017 07:33:40 -0700 |
parents | c71472e6537f |
children | 342e3ea24b5d |
comparison
equal
deleted
inserted
replaced
875:7169bf42ec60 | 876:d1095774bfcf |
---|---|
237 record_histories = ppmngr.record_histories | 237 record_histories = ppmngr.record_histories |
238 current_records = record_histories.current | 238 current_records = record_histories.current |
239 jobctx = PipelineJobCreateContext(0, record_histories) | 239 jobctx = PipelineJobCreateContext(0, record_histories) |
240 jobs = pp.createJobs(jobctx) | 240 jobs = pp.createJobs(jobctx) |
241 for job in jobs: | 241 for job in jobs: |
242 runctx = PipelineJobRunContext( | |
243 job, pp.record_name, record_histories) | |
244 | |
242 ppres = PipelineJobResult() | 245 ppres = PipelineJobResult() |
243 ppres.record_entry = pp.createRecordEntry(job) | 246 ppres.record_entry = pp.createRecordEntry(job, runctx) |
244 | 247 |
245 runctx = PipelineJobRunContext( | |
246 job, pp, record_histories) | |
247 try: | 248 try: |
248 pp.run(job, runctx, ppres) | 249 pp.run(job, runctx, ppres) |
249 except Exception as e: | 250 except Exception as e: |
250 ppres.record_entry.errors.append(str(e)) | 251 ppres.record_entry.errors.append(str(e)) |
251 | 252 |