Browse Source

Fixes bugs with bootsteps: requires attribute not inherited by subclasses and using module paths did not work properly. Closes #2002

Ask Solem 11 years ago
parent
commit
fd4701ce72
1 changed files with 2 additions and 1 deletions
  1. 2 1
      celery/bootsteps.py

+ 2 - 1
celery/bootsteps.py

@@ -232,6 +232,8 @@ class Blueprint(object):
         return next((C for C in values(self.steps) if C.last), None)
 
     def _firstpass(self, steps):
+        for step in values(steps):
+            step.requires = [symbol_by_name(dep) for dep in step.requires]
         stream = deque(step.requires for step in values(steps))
         while stream:
             for node in stream.popleft():
@@ -283,7 +285,6 @@ class StepType(type):
         attrs.update(
             __qualname__=qname,
             name=attrs.get('name') or qname,
-            requires=attrs.get('requires', ()),
         )
         return super(StepType, cls).__new__(cls, name, bases, attrs)