Skip to content

Commit 0ef3e56

Browse files
committed
dlq_purge: Strip dlq. prefix from rabbitmq queues
1 parent 3dc4880 commit 0ef3e56

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/zocalo/cli/dlq_purge.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ def run() -> None:
6060

6161
args = parser.parse_args(["--stomp-prfx=DLQ"] + sys.argv[1:])
6262
if args.transport == "PikaTransport":
63-
queues = ["dlq." + a for a in args.queues]
63+
queues = ["dlq." + a.removeprefix("dlq.") for a in args.queues]
6464
else:
6565
queues = args.queues
6666
transport = workflows.transport.lookup(args.transport)()

0 commit comments

Comments
 (0)