All tests passing!

celery/worker/buckets.py

@@ -150,7 +150,8 @@ class TaskBucket(object):
         will be used.
 
         """
-        assert task_name not in self.buckets
+        if task_name in self.buckets:
+            return
         task_type = self.task_registry[task_name]
         task_queue = Queue()
         rate_limit = getattr(task_type, "rate_limit", None)

celery/worker/job.py

@@ -240,7 +240,6 @@ class TaskWrapper(object):
                             "task_retries": self.retries}
         fun = self.task.run
         supported_keys = fun_takes_kwargs(fun, default_kwargs)
-        print("SUPPORTED KEYS: %s" % (supported_keys))
         extend_with = dict((key, val) for key, val in default_kwargs.items()
                                 if key in supported_keys)
         kwargs.update(extend_with)