a refresh interval of 0 should disable the subqueues detection

Author: Florian Perucki

mrq/worker.py

@@ -424,7 +424,9 @@ def work_init(self):
 
         self.status = "started"
 
-        self.greenlets["subqueues"] = gevent.spawn(self.greenlet_subqueues)
+        # An interval of 0 disables the refresh
+        if self.config["subqueues_refresh_interval"] > 0:
+            self.greenlets["subqueues"] = gevent.spawn(self.greenlet_subqueues)
 
         # An interval of 0 disables the refresh
         if self.config["paused_queues_refresh_interval"] > 0:

tests/test_subqueues.py

@@ -53,3 +53,24 @@ def test_custom_delimiters(worker, delimiter):
     job_id = worker.send_task("tests.tasks.general.GetTime", {}, queue=subqueue, block=False)
     Job(job_id).wait(poll_interval=0.01)
     worker.stop()
+
+
+def test_refresh_interval(worker):
+
+    """ Tests that a refresh interval of 0 disables the subqueue detection """
+
+    worker.start(queues="test/", flags="--subqueues_refresh_interval=0")
+
+    time.sleep(2)
+
+    job_id1 = worker.send_task(
+        "tests.tasks.general.GetTime", {"a": 41},
+        queue="test/subqueue", block=False)
+
+    time.sleep(5)
+
+    job1 = Job(job_id1).fetch().data
+
+    assert job1["status"] == "queued"
+
+    worker.stop()