OLD | NEW |
1 # Copyright 2015 The Swarming 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 by the Apache v2.0 license that can be |
3 # found in the LICENSE file. | 3 # 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 |
(...skipping 192 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
204 | 204 |
205 set_available(ndb.Key(models.CatalogMachineEntry, machine_id)) | 205 set_available(ndb.Key(models.CatalogMachineEntry, machine_id)) |
206 | 206 |
207 | 207 |
208 def create_queues_app(): | 208 def create_queues_app(): |
209 return webapp2.WSGIApplication([ | 209 return webapp2.WSGIApplication([ |
210 ('/internal/queues/fulfill-lease-request', LeaseRequestFulfiller), | 210 ('/internal/queues/fulfill-lease-request', LeaseRequestFulfiller), |
211 ('/internal/queues/reclaim-machine', MachineReclaimer), | 211 ('/internal/queues/reclaim-machine', MachineReclaimer), |
212 ('/internal/queues/subscribe-machine', MachineSubscriber), | 212 ('/internal/queues/subscribe-machine', MachineSubscriber), |
213 ]) | 213 ]) |
OLD | NEW |