task_queues: Add more scaffolding

appengine/swarming/server/bot_management.py

 # Copyright 2014 The LUCI Authors. All rights reserved.
 # Use of this source code is governed under the Apache License, Version 2.0
 # that can be found in the LICENSE file.
 
 """Swarming bot management, e.g. list of known bots and their state.
 
           +---------+
           |BotRoot  |
           |id=bot_id|
           +---------+
                |
-        +------+-------+---------------+---------+----- ... -----+
-        |              |               |         |               |
-        v              v               v         v               v
-    +-------+    +-----------+    +--------+ +--------+     +--------+
-    |BotInfo|    |BotSettings|    |BotEvent| |BotEvent| ... |BotEvent|
-    |id=info|    |id=settings|    |id=fffff| |if=ffffe| ... |id=00000|
-    +-------+    +-----------+    +--------+ +--------+     +--------+
+        +-----++-------+---------------+---------+----- ... -----+
+        |      |        |               |         |               |
+        v      |        v               v         v               v
+    +-------+  |  +-----------+    +--------+ +--------+     +--------+
+    |BotInfo|  |  |BotSettings|    |BotEvent| |BotEvent| ... |BotEvent|
+    |id=info|  |  |id=settings|    |id=fffff| |if=ffffe| ... |id=00000|
+    +-------+  |  +-----------+    +--------+ +--------+     +--------+
+               |
+               +--------------------+
+               |                    |
+               v                    v
+    +-------------------+     +-------------------+
+    |BotTaskDimensions  | ... |BotTaskDimensions  |
+    |id=<dimension_hash>| ... |id=<dimension_hash>|  <task_queues.py>
+    +-------------------+     +-------------------+
 
     +--------Root--------+
     |DimensionAggregation|
     |id='current'        |
     +--------------------+
 
 - BotEvent is a monotonically inserted entity that is added for each event
   happening for the bot.
 - BotInfo is a 'dump-only' entity used for UI, it permits quickly show the
   state of every bots in an single query. It is basically a cache of the last
@@ skipping 427 matching lines @@
   Returns:
     Tuple (True to restart, text message explaining the reason).
   """
   # Periodically reboot bots to workaround OS level leaks (especially on Win).
   running_time = state.get('running_time', 0)
   assert isinstance(running_time, (int, float))
   period = get_bot_reboot_period(bot_id, state)
   if period and running_time > period:
     return True, 'Periodic reboot: running longer than %ds' % period
   return False, ''