Select subset of queues. Arguments: queues (Sequence[str]): a list of queue names to keep.
(self, queues=None)
| 1114 | return now_in_utc.astimezone(self.timezone) |
| 1115 | |
| 1116 | def select_queues(self, queues=None): |
| 1117 | """Select subset of queues. |
| 1118 | |
| 1119 | Arguments: |
| 1120 | queues (Sequence[str]): a list of queue names to keep. |
| 1121 | """ |
| 1122 | return self.amqp.queues.select(queues) |
| 1123 | |
| 1124 | def either(self, default_key, *defaults): |
| 1125 | """Get key from configuration or use default values. |