Browse Source

celery.execute.delay_task was accidentally removed

Ask Solem 14 years ago
parent
commit
b75d12e538
1 changed files with 7 additions and 0 deletions
  1. 7 0
      celery/execute/__init__.py

+ 7 - 0
celery/execute/__init__.py

@@ -14,3 +14,10 @@ def apply_async(task, *args, **kwargs):
 def apply(task, *args, **kwargs):
 def apply(task, *args, **kwargs):
     """*[Deprecated]* Use `task.apply()`"""
     """*[Deprecated]* Use `task.apply()`"""
     return task.apply(*args, **kwargs)
     return task.apply(*args, **kwargs)
+
+
+@deprecated(removal="2.3",
+            alternative="Use registry.tasks[name].delay instead.")
+def delay_task(task, *args, **kwargs):
+    from celery.registry import tasks
+    return tasks[task].apply_async(args, kwargs)