Infer the max zoom to enqueue from metatile size

config.yaml.sample

@@ -84,8 +84,8 @@ tiles:
     # process on update
     parent-zoom-until: 11
 
-  # this is the max zoom used when enqueueing the tiles of interest
-  enqueue_max_zoom: 15
+  # zoom where tile content stops changing
+  max-zoom-with-changes: 16
 
 process:
   # number of simultaneous "querysets" to issue to the database.  The

tests/test_config.py

@@ -41,23 +41,13 @@ def test_merge_override(self):
 
 class TestCliConfiguration(unittest.TestCase):
 
-    def _call_fut(self, args, config_dict):
+    def _call_fut(self, config_dict):
         from tilequeue.config import make_config_from_argparse
         from yaml import dump
+        from cStringIO import StringIO
         raw_yaml = dump(config_dict)
-        return make_config_from_argparse(
-            args,
-            opencfg=self._fp(raw_yaml))
-
-    def _fp(self, raw_yaml):
-        # stub out a file object that has __enter__, __exit__ methods
-        from StringIO import StringIO
-        from contextlib import closing
-        return lambda filename: closing(StringIO(raw_yaml))
-
-    def _args(self, data):
-        # create an object with data as the attributes
-        return type('mock-args', (object,), data)
+        raw_yaml_file_obj = StringIO(raw_yaml)
+        return make_config_from_argparse(raw_yaml_file_obj)
 
     def _assert_cfg(self, cfg, to_check):
         # cfg is the config object to validate
@@ -67,8 +57,7 @@ def _assert_cfg(self, cfg, to_check):
             self.assertEqual(v, cfg_val)
 
     def test_no_config(self):
-        cfg = self._call_fut(
-            self._args(dict(config=None)), {})
+        cfg = self._call_fut(dict(config=None))
         # just assert some of the defaults are set
         self._assert_cfg(cfg,
                          dict(s3_path='osm',
@@ -78,10 +67,49 @@ def test_no_config(self):
 
     def test_config_osm_path_modified(self):
         cfg = self._call_fut(
-            self._args(dict(config='config')),
             dict(store=dict(path='custompath')))
         self._assert_cfg(cfg,
                          dict(s3_path='custompath',
                               output_formats=['json'],
                               seed_all_zoom_start=None,
                               seed_all_zoom_until=None))
+
+
+class TestMetatileConfiguration(unittest.TestCase):
+
+    def _call_fut(self, config_dict):
+        from tilequeue.config import make_config_from_argparse
+        from yaml import dump
+        from cStringIO import StringIO
+        raw_yaml = dump(config_dict)
+        raw_yaml_file_obj = StringIO(raw_yaml)
+        return make_config_from_argparse(raw_yaml_file_obj)
+
+    def test_metatile_size_default(self):
+        config_dict = {}
+        cfg = self._call_fut(config_dict)
+        self.assertIsNone(cfg.metatile_size)
+        self.assertEquals(cfg.metatile_zoom, 0)
+
+    def test_metatile_size_1(self):
+        config_dict = dict(metatile=dict(size=1))
+        cfg = self._call_fut(config_dict)
+        self.assertEquals(cfg.metatile_size, 1)
+        self.assertEquals(cfg.metatile_zoom, 0)
+
+    def test_metatile_size_2(self):
+        config_dict = dict(metatile=dict(size=2))
+        cfg = self._call_fut(config_dict)
+        self.assertEquals(cfg.metatile_size, 2)
+        self.assertEquals(cfg.metatile_zoom, 1)
+
+    def test_metatile_size_4(self):
+        config_dict = dict(metatile=dict(size=4))
+        cfg = self._call_fut(config_dict)
+        self.assertEquals(cfg.metatile_size, 4)
+        self.assertEquals(cfg.metatile_zoom, 2)
+
+    def test_max_zoom(self):
+        config_dict = dict(metatile=dict(size=2))
+        cfg = self._call_fut(config_dict)
+        self.assertEquals(cfg.max_zoom, 15)

tilequeue/command.py

@@ -611,11 +611,11 @@ def tilequeue_process(cfg, peripherals):
     thread_sqs_queue_reader_stop = threading.Event()
     sqs_queue_reader = SqsQueueReader(
         sqs_queue, sqs_input_queue, logger, thread_sqs_queue_reader_stop,
-        cfg.metatile_size)
+        cfg.max_zoom)
 
     data_fetch = DataFetch(
         feature_fetcher, sqs_input_queue, sql_data_fetch_queue, io_pool,
-        peripherals.redis_cache_index, logger, cfg.metatile_size)
+        peripherals.redis_cache_index, logger, cfg.metatile_zoom, cfg.max_zoom)
 
     data_processor = ProcessAndFormatData(
         post_process_data, formats, sql_data_fetch_queue, processor_queue,
@@ -1551,7 +1551,8 @@ def tilequeue_main(argv_args=None):
     args = parser.parse_args(argv_args)
     assert os.path.exists(args.config), \
         'Config file {} does not exist!'.format(args.config)
-    cfg = make_config_from_argparse(args.config)
+    with open(args.config) as fh:
+        cfg = make_config_from_argparse(fh)
     redis_client = make_redis_client(cfg)
     Peripherals = namedtuple('Peripherals', 'redis_cache_index queue stats')
     queue = make_queue(

tilequeue/config.py

@@ -1,5 +1,6 @@
 from tilequeue.tile import bounds_buffer
 from yaml import load
+import math
 
 
 class Configuration(object):
@@ -24,8 +25,6 @@ def __init__(self, yml):
         self.s3_path = self._cfg('store path')
         self.s3_date_prefix = self._cfg('store date-prefix')
 
-        self.enqueue_max_zoom = self.yml['tiles']['enqueue_max_zoom']
-
         seed_cfg = self.yml['tiles']['seed']
         self.seed_all_zoom_start = seed_cfg['all']['zoom-start']
         self.seed_all_zoom_until = seed_cfg['all']['zoom-until']
@@ -104,6 +103,17 @@ def __init__(self, yml):
         self.wof = self.yml.get('wof')
 
         self.metatile_size = self._cfg('metatile size')
+        if self.metatile_size is None:
+            self.metatile_zoom = 0
+        else:
+            self.metatile_zoom = int(math.log(self.metatile_size, 2))
+            assert (1 << self.metatile_zoom) == self.metatile_size, \
+                "Metatile size must be a power of two."
+
+        self.max_zoom_with_changes = self._cfg('tiles max-zoom-with-changes')
+        assert self.max_zoom_with_changes > self.metatile_zoom
+        self.max_zoom = self.max_zoom_with_changes - self.metatile_zoom
+
         self.store_orig = self._cfg('metatile store_metatile_and_originals')
 
         self.sql_queue_buffer_size = self._cfg('queue_buffer_size sql')
@@ -168,7 +178,7 @@ def default_yml_config():
                 'expired-location': None,
                 'parent-zoom-until': None,
             },
-            'enqueue_max_zoom': 15,
+            'max-zoom-with-changes': 16,
         },
         'process': {
             'n-simultaneous-query-sets': 0,
@@ -220,12 +230,11 @@ def merge_cfg(dest, source):
     return dest
 
 
-def make_config_from_argparse(config_path, opencfg=open):
-    # opencfg for testing
-    cfg = default_yml_config()
-    with opencfg(config_path) as config_fp:
-        yml_data = load(config_fp.read())
-        cfg = merge_cfg(cfg, yml_data)
+def make_config_from_argparse(config_file_handle, default_yml=None):
+    if default_yml is None:
+        default_yml = default_yml_config()
+    yml_data = load(config_file_handle)
+    cfg = merge_cfg(default_yml, yml_data)
     return Configuration(cfg)
 
 

tilequeue/worker.py

@@ -12,7 +12,6 @@
 import signal
 import sys
 import time
-import math
 
 
 # long enough to not fight with other threads, but not long enough
@@ -92,20 +91,17 @@ def __call__(self, coord, data):
 
 class SqsQueueReader(object):
 
-    def __init__(self, sqs_queue, output_queue, logger, stop,
-                 metatile_size, sqs_msgs_to_read_size=10):
+    def __init__(
+            self, sqs_queue, output_queue, logger, stop, max_zoom,
+            sqs_msgs_to_read_size=10):
         self.sqs_queue = sqs_queue
         self.output = OutputQueue(output_queue, stop)
         self.sqs_msgs_to_read_size = sqs_msgs_to_read_size
         self.logger = logger
         self.stop = stop
-        self.metatile_zoom = int(math.log(metatile_size, 2))
-        assert (1 << self.metatile_zoom) == metatile_size, \
-            "Metatile size must be a power of two."
+        self.max_zoom = max_zoom
 
     def __call__(self):
-        max_zoom = 16 - self.metatile_zoom
-
         while not self.stop.is_set():
             try:
                 msgs = self.sqs_queue.read(
@@ -120,11 +116,11 @@ def __call__(self):
                 if self.stop.is_set():
                     break
 
-                if msg.coord.zoom > max_zoom:
+                if msg.coord.zoom > self.max_zoom:
                     self.logger.log(
                         logging.WARNING,
                         'Job coordinates above max zoom are not supported, '
-                        'skipping %r > %d' % (msg.coord, max_zoom))
+                        'skipping %r > %d' % (msg.coord, self.max_zoom))
 
                     # delete jobs that we can't handle from the queue,
                     # otherwise we'll get stuck in a cycle of timed-out jobs
@@ -160,17 +156,17 @@ def __call__(self):
 
 class DataFetch(object):
 
-    def __init__(self, fetcher, input_queue, output_queue, io_pool,
-                 redis_cache_index, logger, metatile_size):
+    def __init__(
+            self, fetcher, input_queue, output_queue, io_pool,
+            redis_cache_index, logger, metatile_zoom, max_zoom):
         self.fetcher = fetcher
         self.input_queue = input_queue
         self.output_queue = output_queue
         self.io_pool = io_pool
         self.redis_cache_index = redis_cache_index
         self.logger = logger
-        self.metatile_zoom = int(math.log(metatile_size, 2))
-        assert (1 << self.metatile_zoom) == metatile_size, \
-            "Metatile size must be a power of two."
+        self.metatile_zoom = metatile_zoom
+        self.max_zoom = max_zoom
 
     def __call__(self, stop):
         saw_sentinel = False