Returns the canonical queue name for a given queue.
(queue_name: str)
| 141 | |
| 142 | |
| 143 | def q_name(queue_name: str) -> str: |
| 144 | """Returns the canonical queue name for a given queue.""" |
| 145 | if queue_name.endswith(".DQ") or queue_name.endswith(".XQ"): |
| 146 | return queue_name[:-3] |
| 147 | return queue_name |
| 148 | |
| 149 | |
| 150 | def dq_name(queue_name: str) -> str: |
no outgoing calls