Backend optimized version of :meth:`iterate`. .. versionadded:: 2.2 Note that this does not support collecting the results for different task types using different backends. This is currently only supported by the amqp, Redis and cache result backends.
(self, timeout=None, interval=0.5, no_ack=True,
on_message=None, on_interval=None)
| 789 | return self.on_ready.then(callback, on_error) |
| 790 | |
| 791 | def iter_native(self, timeout=None, interval=0.5, no_ack=True, |
| 792 | on_message=None, on_interval=None): |
| 793 | """Backend optimized version of :meth:`iterate`. |
| 794 | |
| 795 | .. versionadded:: 2.2 |
| 796 | |
| 797 | Note that this does not support collecting the results |
| 798 | for different task types using different backends. |
| 799 | |
| 800 | This is currently only supported by the amqp, Redis and cache |
| 801 | result backends. |
| 802 | """ |
| 803 | return self.backend.iter_native( |
| 804 | self, |
| 805 | timeout=timeout, interval=interval, no_ack=no_ack, |
| 806 | on_message=on_message, on_interval=on_interval, |
| 807 | ) |
| 808 | |
| 809 | def join_native(self, timeout=None, propagate=True, |
| 810 | interval=0.5, callback=None, no_ack=True, |
no outgoing calls