app/soc/views/models/cron.py
changeset 2231 6077018a1e68
parent 2215 c5b7f6bc8c27
child 2232 3c1e0b915803
equal deleted inserted replaced
2230:f3d59025d254 2231:6077018a1e68
    85       filter = {
    85       filter = {
    86           'priority_group': group,
    86           'priority_group': group,
    87           'status': 'waiting',
    87           'status': 'waiting',
    88           }
    88           }
    89 
    89 
    90       query = job_logic.getQueryForFields(filter=filter)
    90       queryGen = lambda: job_logic.getQueryForFields(filter=filter)
    91       jobs = job_logic.getAll(query)
    91       jobs = job_logic.entityIterator(queryGen, batchSize=10)
    92 
    92 
    93       for job in jobs:
    93       for job in jobs:
    94         job_key = job.key().id()
    94         job_key = job.key().id()
    95         good = handler.handle(job_key)
    95         good = handler.handle(job_key)
    96 
    96