Browse Source

Remove celery.task.is_successful (using default_backend)

Ask Solem 15 years ago
parent
commit
dc0d22a322
1 changed files with 4 additions and 14 deletions
  1. 4 14
      celery/task/__init__.py

+ 4 - 14
celery/task/__init__.py

@@ -7,22 +7,12 @@ from billiard.serialization import pickle
 
 
 from celery.execute import apply_async
 from celery.execute import apply_async
 from celery.registry import tasks
 from celery.registry import tasks
-from celery.backends import default_backend
-from celery.task.base import Task, TaskSet, PeriodicTask
-from celery.task.base import ExecuteRemoteTask, AsynchronousMapTask
-from celery.task.rest import RESTProxyTask
+from celery.task.base import Task, TaskSet, PeriodicTask, ExecuteRemoteTask
 from celery.task.control import discard_all
 from celery.task.control import discard_all
-from celery.task.builtins import DeleteExpiredTaskMetaTask, PingTask
-
-
-def is_successful(task_id):
-    """Returns ``True`` if task with ``task_id`` has been executed.
-
-    :rtype: bool
-
-    """
-    return default_backend.is_successful(task_id)
+from celery.task.builtins import PingTask
 
 
+__all__ = ["Task", "TaskSet", "PeriodicTask", "tasks", "discard_all",
+           "is_successful", "dmap", "dmap_async", "execute_remote", "ping"]
 
 
 def dmap(fun, args, timeout=None):
 def dmap(fun, args, timeout=None):
     """Distribute processing of the arguments and collect the results.
     """Distribute processing of the arguments and collect the results.