Browse Source

prefetch multiplier must be int

Ask Solem 12 years ago
parent
commit
6356efc476
1 changed files with 2 additions and 2 deletions
  1. 2 2
      celery/worker/__init__.py

+ 2 - 2
celery/worker/__init__.py

@@ -339,9 +339,9 @@ class WorkController(object):
         self.max_tasks_per_child = self._getopt(
             'max_tasks_per_child', max_tasks_per_child,
         )
-        self.prefetch_multiplier = self._getopt(
+        self.prefetch_multiplier = int(self._getopt(
             'prefetch_multiplier', prefetch_multiplier,
-        )
+        ))
         self.disable_rate_limits = self._getopt(
             'disable_rate_limits', disable_rate_limits,
         )