equal
deleted
inserted
replaced
90 } |
90 } |
91 |
91 |
92 queryGen = lambda: job_logic.getQueryForFields(filter=filter) |
92 queryGen = lambda: job_logic.getQueryForFields(filter=filter) |
93 jobs = job_logic.entityIterator(queryGen, batchSize=10) |
93 jobs = job_logic.entityIterator(queryGen, batchSize=10) |
94 |
94 |
95 for job in jobs: |
95 good = True |
96 if random.randint(0, 5) > 0: |
96 retry_jobs = [] |
|
97 |
|
98 for job in handler.iterate(jobs, retry_jobs): |
|
99 if random.randint(0, 3) > 0: |
|
100 retry_jobs.append(job) |
97 continue |
101 continue |
|
102 |
98 job_key = job.key().id() |
103 job_key = job.key().id() |
99 good = handler.handle(job_key) |
104 status = handler.handle(job_key) |
100 |
105 |
101 if not good: |
106 if status is handler.OUT_OF_TIME: |
102 break |
107 break |
|
108 |
|
109 if status is handler.ERRORED: |
|
110 retry_jobs.append(job) |
103 |
111 |
104 jobs_completed += 1 |
112 jobs_completed += 1 |
105 |
113 |
106 response = 'Completed %d jobs in %d priority groups.' % ( |
114 response = 'Completed %d jobs in %d priority groups.' % ( |
107 jobs_completed, groups_touched) |
115 jobs_completed, groups_touched) |