Skip to content

Commit b7f5fe3

Browse files
authored
Fixed lint error from kombu/transport/native_delayed_delivery.py (#2308)
1 parent 0e04303 commit b7f5fe3

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

kombu/transport/native_delayed_delivery.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -113,8 +113,8 @@ def bind_queue_to_native_delayed_delivery_exchange(connection: Connection, queue
113113
exchange: Exchange = binding_entry.exchange.bind(channel)
114114
if exchange.type == 'direct':
115115
logger.warning(f"Exchange {exchange.name} is a direct exchange "
116-
f"and native delayed delivery do not support direct exchanges.\n"
117-
f"ETA tasks published to this exchange will block the worker until the ETA arrives.")
116+
f"and native delayed delivery do not support direct exchanges.\n"
117+
f"ETA tasks published to this exchange will block the worker until the ETA arrives.")
118118
continue
119119

120120
routing_key = binding_entry.routing_key if binding_entry.routing_key.startswith(

0 commit comments

Comments
 (0)