Skip to content

Commit

Permalink
Ruff satisfied
Browse files Browse the repository at this point in the history
  • Loading branch information
KrySeyt committed Oct 5, 2024
1 parent c4b7aa3 commit 33e4d89
Showing 1 changed file with 3 additions and 7 deletions.
10 changes: 3 additions & 7 deletions faststream/rabbit/subscriber/subscriber.py
Original file line number Diff line number Diff line change
Expand Up @@ -41,16 +41,13 @@ def get_schema(self) -> dict[str, Channel]:
),
bindings=ChannelBinding(
amqp=amqp.ChannelBinding(
**{
"is_": "queue", # type: ignore
"queue": amqp.Queue(
is_="queue", queue=amqp.Queue(
name=self.queue.name,
durable=self.queue.durable,
exclusive=self.queue.exclusive,
autoDelete=self.queue.auto_delete,
vhost=self.virtual_host,
),
"exchange": (
), exchange=(
amqp.Exchange(type="default", vhost=self.virtual_host)
if not self.exchange.name
else amqp.Exchange(
Expand All @@ -60,8 +57,7 @@ def get_schema(self) -> dict[str, Channel]:
autoDelete=self.exchange.auto_delete,
vhost=self.virtual_host,
)
),
}
)
)
),
),
Expand Down

0 comments on commit 33e4d89

Please sign in to comment.