(self, result, timeout=None, interval=0.5,
no_ack=True, on_message=None, on_interval=None,
callback=None, propagate=True)
| 860 | ) |
| 861 | |
| 862 | def wait_for_pending(self, result, timeout=None, interval=0.5, |
| 863 | no_ack=True, on_message=None, on_interval=None, |
| 864 | callback=None, propagate=True): |
| 865 | self._ensure_not_eager() |
| 866 | if on_message is not None: |
| 867 | raise ImproperlyConfigured( |
| 868 | 'Backend does not support on_message callback') |
| 869 | |
| 870 | meta = self.wait_for( |
| 871 | result.id, timeout=timeout, |
| 872 | interval=interval, |
| 873 | on_interval=on_interval, |
| 874 | no_ack=no_ack, |
| 875 | ) |
| 876 | if meta: |
| 877 | result._maybe_set_cache(meta) |
| 878 | return result.maybe_throw(propagate=propagate, callback=callback) |
| 879 | |
| 880 | def wait_for(self, task_id, |
| 881 | timeout=None, interval=0.5, no_ack=True, on_interval=None): |
no test coverage detected