Make worker maximum sleep time configurable

Author: Adrien Chauve

mrq/config.py

@@ -296,6 +296,14 @@ def add_parser_args(parser, config_type):
             type=str,
             help='Overwrite the local IP, to be displayed in the dashboard.')
 
+        parser.add_argument(
+            '--max_sleep',
+            default=1.,
+            type=float,
+            action='store',
+            help='Max seconds while worker may sleep waiting for a new job. '
+                 'Can be < 1.')
+
 
 def get_config(
         sources=(

mrq/worker.py

@@ -408,7 +408,7 @@ def work_loop(self):
                 if len(jobs) < free_pool_slots:
                     self.status = "wait"
                     wait_count += 1
-                    gevent.sleep(min(1, 0.001 * wait_count))
+                    gevent.sleep(min(self.config["max_sleep"], 0.001 * wait_count))
 
         except StopRequested:
             pass