Переглянути джерело

delay_task returns PendingResult()

Ask Solem 16 роки тому
батько
коміт
2c3bd9f9e9
2 змінених файлів з 1 додано та 5 видалено
  1. 0 4
      celery/backends/__init__.py
  2. 1 1
      celery/task.py

+ 0 - 4
celery/backends/__init__.py

@@ -14,9 +14,5 @@ def get_backend_cls(backend):
     return getattr(backend_module, 'Backend')
     return getattr(backend_module, 'Backend')
 
 
 get_default_backend_cls = partial(get_backend_cls, CELERY_BACKEND)
 get_default_backend_cls = partial(get_backend_cls, CELERY_BACKEND)
-
-
 DefaultBackend = get_default_backend_cls()
 DefaultBackend = get_default_backend_cls()
-
-
 default_backend = DefaultBackend()
 default_backend = DefaultBackend()

+ 1 - 1
celery/task.py

@@ -62,7 +62,7 @@ def delay_task(task_name, *args, **kwargs):
     publisher = TaskPublisher(connection=DjangoAMQPConnection())
     publisher = TaskPublisher(connection=DjangoAMQPConnection())
     task_id = publisher.delay_task(task_name, *args, **kwargs)
     task_id = publisher.delay_task(task_name, *args, **kwargs)
     publisher.close()
     publisher.close()
-    return Job(task_id)
+    return PendingResult(task_id)
 
 
 
 
 def discard_all():
 def discard_all():