Add new task queue that'll be consumed from. The queue will be active even when a subset has been selected using the :option:`celery worker -Q` option.
(self, queue, **kwargs)
| 155 | return info[0] + '\n' + textindent('\n'.join(info[1:]), indent) |
| 156 | |
| 157 | def select_add(self, queue, **kwargs): |
| 158 | """Add new task queue that'll be consumed from. |
| 159 | |
| 160 | The queue will be active even when a subset has been selected |
| 161 | using the :option:`celery worker -Q` option. |
| 162 | """ |
| 163 | q = self.add(queue, **kwargs) |
| 164 | if self._consume_from is not None: |
| 165 | self._consume_from[q.name] = q |
| 166 | return q |
| 167 | |
| 168 | def select(self, include): |
| 169 | """Select a subset of currently defined queues to consume from. |