| OLD | NEW |
| 1 # Copyright 2015 The LUCI Authors. All rights reserved. | 1 # Copyright 2015 The LUCI Authors. All rights reserved. |
| 2 # Use of this source code is governed by the Apache v2.0 license that can be | 2 # Use of this source code is governed under the Apache License, Version 2.0 |
| 3 # found in the LICENSE file. | 3 # that can be found in the LICENSE file. |
| 4 | 4 |
| 5 """Task queues for fulfilling lease requests.""" | 5 """Task queues for fulfilling lease requests.""" |
| 6 | 6 |
| 7 import json | 7 import json |
| 8 import logging | 8 import logging |
| 9 | 9 |
| 10 from google.appengine.ext import ndb | 10 from google.appengine.ext import ndb |
| 11 import webapp2 | 11 import webapp2 |
| 12 | 12 |
| 13 from components import decorators | 13 from components import decorators |
| (...skipping 200 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 214 | 214 |
| 215 set_available(ndb.Key(models.CatalogMachineEntry, machine_id)) | 215 set_available(ndb.Key(models.CatalogMachineEntry, machine_id)) |
| 216 | 216 |
| 217 | 217 |
| 218 def create_queues_app(): | 218 def create_queues_app(): |
| 219 return webapp2.WSGIApplication([ | 219 return webapp2.WSGIApplication([ |
| 220 ('/internal/queues/fulfill-lease-request', LeaseRequestFulfiller), | 220 ('/internal/queues/fulfill-lease-request', LeaseRequestFulfiller), |
| 221 ('/internal/queues/reclaim-machine', MachineReclaimer), | 221 ('/internal/queues/reclaim-machine', MachineReclaimer), |
| 222 ('/internal/queues/subscribe-machine', MachineSubscriber), | 222 ('/internal/queues/subscribe-machine', MachineSubscriber), |
| 223 ]) | 223 ]) |
| OLD | NEW |