(self, result, timeout=None, interval=0.5, no_ack=True,
on_message=None, on_interval=None)
| 840 | |
| 841 | class SyncBackendMixin: |
| 842 | def iter_native(self, result, timeout=None, interval=0.5, no_ack=True, |
| 843 | on_message=None, on_interval=None): |
| 844 | self._ensure_not_eager() |
| 845 | results = result.results |
| 846 | if not results: |
| 847 | return |
| 848 | |
| 849 | task_ids = set() |
| 850 | for result in results: |
| 851 | if isinstance(result, ResultSet): |
| 852 | yield result.id, result.results |
| 853 | else: |
| 854 | task_ids.add(result.id) |
| 855 | |
| 856 | yield from self.get_many( |
| 857 | task_ids, |
| 858 | timeout=timeout, interval=interval, no_ack=no_ack, |
| 859 | on_message=on_message, on_interval=on_interval, |
| 860 | ) |
| 861 | |
| 862 | def wait_for_pending(self, result, timeout=None, interval=0.5, |
| 863 | no_ack=True, on_message=None, on_interval=None, |
nothing calls this directly
no test coverage detected