Ask Solem преди 12 години
родител
ревизия
e9fb32454d
променени са 2 файла, в които са добавени 1 реда и са изтрити 2 реда
  1. 1 1
      celery/bin/celery.py
  2. 0 1
      celery/canvas.py

+ 1 - 1
celery/bin/celery.py

@@ -515,7 +515,7 @@ class _RemoteControl(Command):
         destination = kwargs.get('destination')
         timeout = kwargs.get('timeout') or self.choices[method][0]
         if destination and isinstance(destination, basestring):
-            destination = [str.strip(v) for v in destination.split(',')]
+            destination = [v.strip() for v in destination.split(',')]
 
         try:
             handler = getattr(self, method)

+ 0 - 1
celery/canvas.py

@@ -404,7 +404,6 @@ class group(Signature):
         # consolidate tasks with the same app and apply them in
         # batches.
         type = tasks[0].type.app.tasks[self['task']]
-        tasks, result, gid, args = type.prepare(options, tasks, partial_args)
         return type(*type.prepare(options, tasks, partial_args))
 
     def _freeze(self, _id=None):