Quellcode durchsuchen

AsyncResult.get did not support the interal and propagate arguments

Ask Solem vor 14 Jahren
Ursprung
Commit
7e153ebfe5
1 geänderte Dateien mit 4 neuen und 4 gelöschten Zeilen
  1. 4 4
      celery/result.py

+ 4 - 4
celery/result.py

@@ -54,7 +54,7 @@ class BaseAsyncResult(object):
         self.app.control.revoke(self.task_id, connection=connection,
                                 connect_timeout=connect_timeout)
 
-    def wait(self, timeout=None, propagate=True, interval=0.5):
+    def get(self, timeout=None, propagate=True, interval=0.5):
         """Wait until task is ready, and return its result.
 
         .. warning::
@@ -82,9 +82,9 @@ class BaseAsyncResult(object):
                                                    propagate=propagate,
                                                    interval=interval)
 
-    def get(self, timeout=None):
-        """Alias to :meth:`wait`."""
-        return self.wait(timeout=timeout)
+    def wait(self, **kwargs):
+        """Deprecated alias to :meth:`get`."""
+        return self.get(**kwargs)
 
     def ready(self):
         """Returns :const:`True` if the task has been executed.