Renamed celery.buckets -> celery.worker.buckets

celery/tests/test_buckets.py

@@ -5,7 +5,7 @@ import time
 import unittest
 from itertools import chain, izip
 
-from celery import buckets
+from celery.worker import buckets
 from celery.utils import gen_unique_id
 from celery.registry import TaskRegistry
 from celery.task.base import Task

celery/worker/__init__.py

@@ -19,7 +19,7 @@ from celery.utils import retry_over_time
 from celery.worker.job import TaskWrapper
 from celery.worker.scheduler import Scheduler
 from celery.worker.controllers import Mediator, ScheduleController
-from celery.buckets import TaskBucket
+from celery.worker.buckets import TaskBucket
 from celery.messaging import get_consumer_set
 from celery.exceptions import NotRegistered
 from celery.datastructures import SharedCounter